@Test public void testValidSingleRecordDirect() throws UnknownHostException { givenNextRecordIs(defaultValues); QueueReader reader = givenReader(); StoredAuditRecord auditRecord = reader.nextRecord(); assertRecordMatchesWire(auditRecord, defaultValues); }
public StoredAuditRecord nextRecord() { maybeReadNext(); StoredAuditRecord entry = nextRecord; nextRecord = null; return entry; }
QueueReader { public StoredAuditRecord nextRecord() { maybeReadNext(); StoredAuditRecord entry = nextRecord; nextRecord = null; return entry; } }
QueueReader { public StoredAuditRecord nextRecord() { maybeReadNext(); StoredAuditRecord entry = nextRecord; nextRecord = null; return entry; } QueueReader(ToolOptions toolOptions);   QueueReader(ToolOptions toolOptions, ChronicleQueue chronicleQueue); }
QueueReader { public StoredAuditRecord nextRecord() { maybeReadNext(); StoredAuditRecord entry = nextRecord; nextRecord = null; return entry; } QueueReader(ToolOptions toolOptions);   QueueReader(ToolOptions toolOptions, ChronicleQueue chronicleQueue); boolean hasRecordAvailable(); StoredAuditRecord nextRecord(); }
QueueReader { public StoredAuditRecord nextRecord() { maybeReadNext(); StoredAuditRecord entry = nextRecord; nextRecord = null; return entry; } QueueReader(ToolOptions toolOptions);   QueueReader(ToolOptions toolOptions, ChronicleQueue chronicleQueue); boolean hasRecordAvailable(); StoredAuditRecord nextRecord();  }