added some time between msg arrival in close in test to make sure ack…

…s get to server
nats-io · Sep 17, 2018 · d46527f · d46527f
1 parent 3135852
commit d46527f
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/test/java/io/nats/streaming/SubscribeTests.java b/src/test/java/io/nats/streaming/SubscribeTests.java
@@ -799,6 +799,7 @@ public void testDurableSubscriberCloseVersusUnsub() throws Exception {
                         latch.await(5, TimeUnit.SECONDS));
                 assertEquals("should get first message", 0, received.get());
 
+                try {Thread.sleep(2000);} catch(Exception e) {}; // get the ack in the queue
                 sub.close(); // Should not unsub
                 sc.getNatsConnection().flush(Duration.ofSeconds(2));
                 try {Thread.sleep(2000);} catch(Exception e) {}; // Give the server time to clean up
@@ -824,6 +825,7 @@ public void testDurableSubscriberCloseVersusUnsub() throws Exception {
                         latch2.await(5, TimeUnit.SECONDS));
                 assertEquals("should get second message", 1, received.get());
 
+                try {Thread.sleep(2000);} catch(Exception e) {}; // get the ack in the queue
                 sub2.close(true); // Should unsub
                 sc.getNatsConnection().flush(Duration.ofSeconds(2));
                 try {Thread.sleep(2000);} catch(Exception e) {}; // Give the server time to clean up