mirror of
https://github.com/elastic/logstash.git
synced 2025-04-25 07:07:54 -04:00
parent
245e206e83
commit
e78e79f6cb
1 changed files with 1 additions and 1 deletions
|
@ -456,7 +456,7 @@ public class QueueTest {
|
|||
|
||||
assertThat(q.isFull(), is(true));
|
||||
|
||||
Batch b = q.readBatch(9); // read 1 page (10 events)
|
||||
Batch b = q.readBatch(10); // read 1 page (10 events)
|
||||
b.close(); // purge 1 page
|
||||
|
||||
// spin wait until data is written and write blocks
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue