fixed test case

OpenHFT · Apr 4, 2016 · 7e13664 · 7e13664
1 parent 081384a
commit 7e13664
Showing 1 changed file with 11 additions and 4 deletions.
diff --git a/src/test/java/net/openhft/chronicle/queue/impl/single/SingleChronicleQueueTest.java b/src/test/java/net/openhft/chronicle/queue/impl/single/SingleChronicleQueueTest.java
@@ -877,13 +877,20 @@ public void testReadingSecondDocumentNotExistIncludingMeta() {
             }
 
             final ExcerptTailer tailer = chronicle.createTailer();
+            StringBuilder event = new StringBuilder();
+            while (true) {
+                try (DocumentContext dc = tailer.readingDocument(true)) {
 
-            try (DocumentContext dc = tailer.readingDocument(true)) {
+                    ValueIn in = dc.wire().read(event);
-                String text = dc.wire().read(() -> "FirstName").text();
+                    if (!StringUtils.isEqual(event, "FirstName"))
-                Assert.assertEquals("Quartilla", text);
+                        continue;
+
+                    in.text("Quartilla", Assert::assertEquals);
+                    break;
+                }
             }
 
-            try (DocumentContext dc = tailer.readingDocument(true)) {
+            try (DocumentContext dc = tailer.readingDocument()) {
                 assertFalse(dc.isPresent());
             }
         }