@Test public void testNothingToReadDirect() { when(tailer.readDocument(any(ReadMarshallable.class))).thenReturn(false); QueueReader reader = givenReader(); assertThat(reader.nextRecord()).isNull(); }
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();  }