implements countMessages and removeQueue in PhpAmqpDriver

bernardphp · Nov 6, 2016 · ae42b2c · ae42b2c
1 parent bdb69cb
commit ae42b2c
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);
     }
 
     /**