Improved timeout in LiveTest.PoisonedMessageHandler

jendakol · jendakol · commit 351b4766fdcb · 2018-05-10T14:17:41.000+02:00
diff --git a/core/src/test/scala/com/avast/clients/rabbitmq/LiveTest.scala b/core/src/test/scala/com/avast/clients/rabbitmq/LiveTest.scala
@@ -345,7 +345,7 @@ class LiveTest extends FunSuite with Eventually with ScalaFutures with StrictLog
       sender.send("test", Bytes.copyFromUtf8(Random.nextString(10))).runAsync.futureValue
     }
 
-    eventually {
+    eventually(timeout = timeout(Span(5, Seconds))) {
       assertResult(20)(processed.get())
       assertResult(0)(testHelper.getMessagesCount(queueName))
       assertResult(10)(poisoned.get())

Original file line number	Diff line number	Diff line change
`@@ -345,7 +345,7 @@ class LiveTest extends FunSuite with Eventually with ScalaFutures with StrictLog`
`345`	`345`	`sender.send("test", Bytes.copyFromUtf8(Random.nextString(10))).runAsync.futureValue`
`346`	`346`	`}`
`347`	`347`
`348`		`- eventually {`
	`348`	`+ eventually(timeout = timeout(Span(5, Seconds))) {`
`349`	`349`	`assertResult(20)(processed.get())`
`350`	`350`	`assertResult(0)(testHelper.getMessagesCount(queueName))`
`351`	`351`	`assertResult(10)(poisoned.get())`