Merge pull request #262 from Solodkiy/fix-some-empty-amqp-methods

implements countMessages and removeQueue in PhpAmqpDriver
bernardphp · Dec 18, 2016 · 8e5884c · 8e5884c
2 parents ed1d019 + ae42b2c
commit 8e5884c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/Driver/PhpAmqpDriver.php b/src/Driver/PhpAmqpDriver.php
@@ -69,6 +69,8 @@ public function createQueue($queueName)
      */
     public function countMessages($queueName)
     {
+        list($queue, $messageCount, $consumerCount) = $this->getChannel()->queue_declare($queueName, true);
+        return $messageCount;
     }
 
     /**
@@ -136,6 +138,7 @@ public function peekQueue($queueName, $index = 0, $limit = 20)
      */
     public function removeQueue($queueName)
     {
+        $this->getChannel()->queue_delete($queueName);
     }
 
     /**