implement size() method

AaronJan · web-flow · commit 04b947ac2d7d · 2017-07-11T18:29:08.000+08:00
diff --git a/src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/RabbitMQQueue.php b/src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/RabbitMQQueue.php
@@ -71,7 +71,9 @@ public function __construct(AMQPStreamConnection $amqpConnection, $config)
      */
     public function size($queue = null)
     {
-        // TODO: Implement size() method.
+        list(, $messageCount) = $this->channel->queue_declare($this->getQueueName($queue), true);
+
+        return $messageCount;
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -71,7 +71,9 @@ public function __construct(AMQPStreamConnection $amqpConnection, $config)`
`71`	`71`	`*/`
`72`	`72`	`public function size($queue = null)`
`73`	`73`	`{`
`74`		`- // TODO: Implement size() method.`
	`74`	`+ list(, $messageCount) = $this->channel->queue_declare($this->getQueueName($queue), true);`
	`75`	`+`
	`76`	`+ return $messageCount;`
`75`	`77`	`}`
`76`	`78`
`77`	`79`	`/**`