Calling AmqpContext::declareQueue() now returns an integer holding the

queue message count

Author: J7mbo

Diff for: pkg/amqp-ext/AmqpContext.php

@@ -114,6 +114,8 @@ public function deleteQueue(PsrDestination $destination)
 
     /**
      * @param AmqpQueue|PsrDestination $destination
+     *
+     * @return int
      */
     public function declareQueue(PsrDestination $destination)
     {
@@ -127,11 +129,13 @@ public function declareQueue(PsrDestination $destination)
             $extQueue->setName($destination->getQueueName());
         }
 
-        $extQueue->declareQueue();
+        $count = $extQueue->declareQueue();
 
         if (false == $destination->getQueueName()) {
             $destination->setQueueName($extQueue->getName());
         }
+
+        return $count;
     }
 
     /**