From 04b947ac2d7dc11e6a784a58de1cb32094c16365 Mon Sep 17 00:00:00 2001 From: AaronJan Date: Tue, 11 Jul 2017 18:29:08 +0800 Subject: [PATCH 1/2] implement `size()` method --- .../LaravelQueueRabbitMQ/Queue/RabbitMQQueue.php | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/RabbitMQQueue.php b/src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/RabbitMQQueue.php index 3bd29dd2..b5f952c1 100644 --- 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; } /** From ddf5dd0e29589cf4910ec6ff53988d59add60981 Mon Sep 17 00:00:00 2001 From: AaronJan Date: Tue, 11 Jul 2017 23:07:13 +0800 Subject: [PATCH 2/2] fix travis CI --- tests/RabbitMQQueueTest.php | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) diff --git a/tests/RabbitMQQueueTest.php b/tests/RabbitMQQueueTest.php index ec6fac9b..7180a3e8 100644 --- a/tests/RabbitMQQueueTest.php +++ b/tests/RabbitMQQueueTest.php @@ -48,7 +48,18 @@ public function setUp() public function test_size() { - $this->queue->size(); + $messageCount = 5; + $consumerCount = 1; + + $this->channel->shouldReceive('queue_declare')->with( + $this->config['queue'], + true + )->once() + ->andReturn([$this->config['queue'], $messageCount, $consumerCount]); + + $size = $this->queue->size(); + + $this->assertEquals($messageCount, $size); } public function test_push()