Wait a bit so that stages can stop correctly

akka · Feb 22, 2019 · a3412dd · a3412dd
1 parent aab2af9
commit a3412dd
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/amqp/src/test/java/docs/javadsl/AmqpDocsTest.java b/amqp/src/test/java/docs/javadsl/AmqpDocsTest.java
@@ -341,5 +341,9 @@ public void republishMessageWithoutAutoAckIfNacked() throws Exception {
             .stream()
             .map(m -> m.message().bytes().utf8String())
             .collect(Collectors.toList()));
+
+    // See https://github.com/akka/akka/issues/26410
+    // extra wait before assertAllStagesStopped kicks in
+    Thread.sleep(3 * 1000);
   }
 }