Set delevery tags on AMQP

php-enqueue · Aug 1, 2024 · e627cd4 · e627cd4
1 parent 0315e5b
commit e627cd4
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/Tests/Functional/AmqpCommonUseCasesTest.php b/Tests/Functional/AmqpCommonUseCasesTest.php
@@ -112,6 +112,7 @@ public function testProduceAndReceiveOneMessageSentDirectlyToTemporaryQueue()
         $queue = $this->amqpContext->createTemporaryQueue();
 
         $message = $this->amqpContext->createMessage(__METHOD__);
+        $message->setDeliveryTag(145);
 
         $producer = $this->amqpContext->createProducer();
         $producer->send($queue, $message);
@@ -137,6 +138,7 @@ public function testProduceAndReceiveOneMessageSentDirectlyToTopic()
         $this->amqpContext->bind(new AmqpBind($topic, $queue));
 
         $message = $this->amqpContext->createMessage(__METHOD__);
+        $message->setDeliveryTag(145);
 
         $producer = $this->amqpContext->createProducer();
         $producer->send($topic, $message);
@@ -158,10 +160,11 @@ public function testConsumerReceiveMessageFromTopicDirectly()
         $this->amqpContext->declareTopic($topic);
 
         $consumer = $this->amqpContext->createConsumer($topic);
-        //guard
+        // guard
         $this->assertNull($consumer->receive(1000));
 
         $message = $this->amqpContext->createMessage(__METHOD__);
+        $message->setDeliveryTag(145);
 
         $producer = $this->amqpContext->createProducer();
         $producer->send($topic, $message);
@@ -181,10 +184,11 @@ public function testConsumerReceiveMessageWithZeroTimeout()
         $this->amqpContext->declareTopic($topic);
 
         $consumer = $this->amqpContext->createConsumer($topic);
-        //guard
+        // guard
         $this->assertNull($consumer->receive(1000));
 
         $message = $this->amqpContext->createMessage(__METHOD__);
+        $message->setDeliveryTag(145);
 
         $producer = $this->amqpContext->createProducer();
         $producer->send($topic, $message);
@@ -205,6 +209,7 @@ public function testPurgeMessagesFromQueue()
         $consumer = $this->amqpContext->createConsumer($queue);
 
         $message = $this->amqpContext->createMessage(__METHOD__);
+        $message->setDeliveryTag(145);
 
         $producer = $this->amqpContext->createProducer();
         $producer->send($queue, $message);