Merge pull request #66 from J7mbo/declare-queue-count

Calling AmqpContext::declareQueue() now returns an integer holding the queue message count
php-enqueue · May 26, 2017 · ba9859c · ba9859c
2 parents 4bbc5da + d30ce41
commit ba9859c
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/amqp-ext/AmqpContext.php b/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;
     }
 
     /**