File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
core/src/test/scala/com/avast/clients/rabbitmq Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -28,6 +28,8 @@ class LiveTest extends FunSuite with Eventually with ScalaFutures with StrictLog
2828
2929 import com .avast .clients .rabbitmq .api .DeliveryResult ._
3030
31+ private implicit val p : PatienceConfig = PatienceConfig (timeout = Span (5 , Seconds ))
32+
3133 private def createConfig () = new {
3234
3335 val queueName = randomString(10 )
@@ -345,7 +347,7 @@ class LiveTest extends FunSuite with Eventually with ScalaFutures with StrictLog
345347 sender.send(" test" , Bytes .copyFromUtf8(Random .nextString(10 ))).runAsync.futureValue
346348 }
347349
348- eventually(timeout = timeout( Span ( 5 , Seconds ))) {
350+ eventually {
349351 assertResult(20 )(processed.get())
350352 assertResult(0 )(testHelper.getMessagesCount(queueName))
351353 assertResult(10 )(poisoned.get())
You can’t perform that action at this time.
0 commit comments