fix delivery tag

Author: makasim

pkg/amqp-bunny/AmqpContext.php

@@ -327,7 +327,7 @@ public function convertMessage(Message $bunnyMessage): InteropAmqpMessage
         }
 
         $message = new AmqpMessage($bunnyMessage->content, $properties, $headers);
-        $message->setDeliveryTag((string) $bunnyMessage->deliveryTag);
+        $message->setDeliveryTag((int) $bunnyMessage->deliveryTag);
         $message->setRedelivered($bunnyMessage->redelivered);
         $message->setRoutingKey($bunnyMessage->routingKey);
 

pkg/amqp-bunny/Tests/AmqpConsumerTest.php

@@ -68,7 +68,7 @@ public function testOnAcknowledgeShouldAcknowledgeMessage()
             ->method('ack')
             ->with($this->isInstanceOf(Message::class))
             ->willReturnCallback(function (Message $message) {
-                $this->assertSame('theDeliveryTag', $message->deliveryTag);
+                $this->assertSame(145, $message->deliveryTag);
             });
 
         $context = $this->createContextMock();
@@ -81,7 +81,7 @@ public function testOnAcknowledgeShouldAcknowledgeMessage()
         $consumer = new AmqpConsumer($context, new AmqpQueue('aName'));
 
         $message = new AmqpMessage();
-        $message->setDeliveryTag('theDeliveryTag');
+        $message->setDeliveryTag(145);
 
         $consumer->acknowledge($message);
     }
@@ -94,7 +94,7 @@ public function testOnRejectShouldRejectMessage()
             ->method('reject')
             ->with($this->isInstanceOf(Message::class), false)
             ->willReturnCallback(function (Message $message) {
-                $this->assertSame('theDeliveryTag', $message->deliveryTag);
+                $this->assertSame(167, $message->deliveryTag);
             });
 
         $context = $this->createContextMock();
@@ -107,7 +107,7 @@ public function testOnRejectShouldRejectMessage()
         $consumer = new AmqpConsumer($context, new AmqpQueue('aName'));
 
         $message = new AmqpMessage();
-        $message->setDeliveryTag('theDeliveryTag');
+        $message->setDeliveryTag(167);
 
         $consumer->reject($message, false);
     }
@@ -120,7 +120,7 @@ public function testOnRejectShouldRequeueMessage()
             ->method('reject')
             ->with($this->isInstanceOf(Message::class), true)
             ->willReturnCallback(function (Message $message) {
-                $this->assertSame('theDeliveryTag', $message->deliveryTag);
+                $this->assertSame(178, $message->deliveryTag);
             });
 
         $context = $this->createContextMock();
@@ -133,7 +133,7 @@ public function testOnRejectShouldRequeueMessage()
         $consumer = new AmqpConsumer($context, new AmqpQueue('aName'));
 
         $message = new AmqpMessage();
-        $message->setDeliveryTag('theDeliveryTag');
+        $message->setDeliveryTag(178);
 
         $consumer->reject($message, true);
     }

pkg/amqp-lib/AmqpContext.php

@@ -309,7 +309,7 @@ public function convertMessage(LibAMQPMessage $amqpMessage): InteropAmqpMessage
         unset($headers['application_headers']);
 
         $message = new AmqpMessage($amqpMessage->getBody(), $properties, $headers);
-        $message->setDeliveryTag($amqpMessage->delivery_info['delivery_tag']);
+        $message->setDeliveryTag((int) $amqpMessage->delivery_info['delivery_tag']);
         $message->setRedelivered($amqpMessage->delivery_info['redelivered']);
         $message->setRoutingKey($amqpMessage->delivery_info['routing_key']);
 

pkg/amqp-lib/Tests/AmqpConsumerTest.php

@@ -67,7 +67,7 @@ public function testOnAcknowledgeShouldAcknowledgeMessage()
         $channel
             ->expects($this->once())
             ->method('basic_ack')
-            ->with('delivery-tag')
+            ->with(167)
         ;
 
         $context = $this->createContextMock();
@@ -80,7 +80,7 @@ public function testOnAcknowledgeShouldAcknowledgeMessage()
         $consumer = new AmqpConsumer($context, new AmqpQueue('aName'));
 
         $message = new AmqpMessage();
-        $message->setDeliveryTag('delivery-tag');
+        $message->setDeliveryTag(167);
 
         $consumer->acknowledge($message);
     }
@@ -91,7 +91,7 @@ public function testOnRejectShouldRejectMessage()
         $channel
             ->expects($this->once())
             ->method('basic_reject')
-            ->with('delivery-tag', $this->isTrue())
+            ->with(125, $this->isTrue())
         ;
 
         $context = $this->createContextMock();
@@ -104,7 +104,7 @@ public function testOnRejectShouldRejectMessage()
         $consumer = new AmqpConsumer($context, new AmqpQueue('aName'));
 
         $message = new AmqpMessage();
-        $message->setDeliveryTag('delivery-tag');
+        $message->setDeliveryTag(125);
 
         $consumer->reject($message, true);
     }