set routing key in consumed message

Author: ASKozienko

pkg/amqp-ext/AmqpConsumer.php

@@ -287,6 +287,7 @@ private function convertMessage(\AMQPEnvelope $extEnvelope)
         );
         $message->setRedelivered($extEnvelope->isRedelivery());
         $message->setDeliveryTag($extEnvelope->getDeliveryTag());
+        $message->setRoutingKey($extEnvelope->getRoutingKey());
 
         return $message;
     }

pkg/amqp-lib/AmqpConsumer.php

@@ -196,6 +196,7 @@ private function convertMessage(LibAMQPMessage $amqpMessage)
         $message = new AmqpMessage($amqpMessage->getBody(), $properties, $headers);
         $message->setDeliveryTag($amqpMessage->delivery_info['delivery_tag']);
         $message->setRedelivered($amqpMessage->delivery_info['redelivered']);
+        $message->setRoutingKey($amqpMessage->delivery_info['routing_key']);
 
         return $message;
     }

pkg/amqp-lib/AmqpContext.php

@@ -124,10 +124,10 @@ public function createProducer()
      */
     public function createTemporaryQueue()
     {
-        $queue = $this->createQueue(null);
-        $queue->addFlag(InteropAmqpQueue::FLAG_EXCLUSIVE);
+        list($name) = $this->getChannel()->queue_declare('', false, false, true, false);
 
-        $this->declareQueue($queue);
+        $queue = $this->createQueue($name);
+        $queue->addFlag(InteropAmqpQueue::FLAG_EXCLUSIVE);
 
         return $queue;
     }
@@ -166,7 +166,7 @@ public function deleteTopic(InteropAmqpTopic $topic)
      */
     public function declareQueue(InteropAmqpQueue $queue)
     {
-        return $this->getChannel()->queue_declare(
+        list(, $messageCount) = $this->getChannel()->queue_declare(
             $queue->getQueueName(),
             (bool) ($queue->getFlags() & InteropAmqpQueue::FLAG_PASSIVE),
             (bool) ($queue->getFlags() & InteropAmqpQueue::FLAG_DURABLE),
@@ -175,6 +175,8 @@ public function declareQueue(InteropAmqpQueue $queue)
             (bool) ($queue->getFlags() & InteropAmqpQueue::FLAG_NOWAIT),
             $queue->getArguments()
         );
+
+        return $messageCount;
     }
 
     /**