Move receive timeout to const

snapshotpl · snapshotpl · commit f2e7fd1c82af · 2020-07-30T14:19:01.000+02:00
diff --git a/pkg/enqueue-bundle/Tests/Functional/UseCasesTest.php b/pkg/enqueue-bundle/Tests/Functional/UseCasesTest.php
@@ -18,6 +18,8 @@
  */
 class UseCasesTest extends WebTestCase
 {
+    const RECEIVE_TIMEOUT = 500;
+
     public function setUp()
     {
         // do not call parent::setUp.
@@ -172,7 +174,7 @@ public function testProducerSendsEventMessage(array $enqueueConfig)
 
         $consumer = $this->getContext()->createConsumer($this->getTestQueue());
 
-        $message = $consumer->receive(100);
+        $message = $consumer->receive(self::RECEIVE_TIMEOUT);
         $this->assertInstanceOf(Message::class, $message);
         $consumer->acknowledge($message);
 
@@ -192,7 +194,7 @@ public function testProducerSendsCommandMessage(array $enqueueConfig)
 
         $consumer = $this->getContext()->createConsumer($this->getTestQueue());
 
-        $message = $consumer->receive(100);
+        $message = $consumer->receive(self::RECEIVE_TIMEOUT);
         $this->assertInstanceOf(Message::class, $message);
         $consumer->acknowledge($message);
 
@@ -220,7 +222,7 @@ public function testProducerSendsEventMessageViaProduceCommand()
 
         $consumer = $this->getContext()->createConsumer($this->getTestQueue());
 
-        $message = $consumer->receive(500);
+        $message = $consumer->receive(self::RECEIVE_TIMEOUT);
         $this->assertInstanceOf(Message::class, $message);
         $consumer->acknowledge($message);
 
@@ -247,7 +249,7 @@ public function testProducerSendsCommandMessageViaProduceCommand()
 
         $consumer = $this->getContext()->createConsumer($this->getTestQueue());
 
-        $message = $consumer->receive(100);
+        $message = $consumer->receive(self::RECEIVE_TIMEOUT);
         $this->assertInstanceOf(Message::class, $message);
         $consumer->acknowledge($message);
 
