Add DequeuerInterface to BaseConsumer.

RabbitMq/BaseConsumer.php

@@ -2,9 +2,7 @@
 
 namespace OldSound\RabbitMqBundle\RabbitMq;
 
-use OldSound\RabbitMqBundle\RabbitMq\BaseAmqp;
-
-abstract class BaseConsumer extends BaseAmqp
+abstract class BaseConsumer extends BaseAmqp implements DequeuerInterface
 {
     protected $target;
 

RabbitMq/DequeuerAwareInterface.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace OldSound\RabbitMqBundle\RabbitMq;
+
+interface DequeuerAwareInterface
+{
+    public function setDequeuer(DequeuerInterface $dequeuer);
+}

RabbitMq/DequeuerInterface.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace OldSound\RabbitMqBundle\RabbitMq;
+
+interface DequeuerInterface
+{
+    /**
+     * Stop dequeuing messages.
+     *
+     * @return void
+     */
+    public function forceStopConsumer();
+
+    /**
+     * Set idle timeout
+     *
+     * @param $idleTimeout
+     *
+     * @return void
+     */
+    public function setIdleTimeout($idleTimeout);
+
+    /**
+     * Get current idle timeout
+     *
+     * @return int
+     */
+    public function getIdleTimeout();
+}

Tests/RabbitMq/BaseConsumerTest.php

@@ -0,0 +1,46 @@
+<?php
+
+namespace OldSound\RabbitMqBundle\Tests\RabbitMq;
+
+use OldSound\RabbitMqBundle\RabbitMq\BaseConsumer;
+
+class BaseConsumerTest extends \PHPUnit_Framework_TestCase
+{
+    /** @var BaseConsumer */
+    protected $consumer;
+
+    protected function setUp()
+    {
+        $amqpConnection =  $this->getMockBuilder('\PhpAmqpLib\Connection\AMQPConnection')
+            ->disableOriginalConstructor()
+            ->getMock();
+
+        $this->consumer = $this->getMockBuilder('\OldSound\RabbitMqBundle\RabbitMq\BaseConsumer')
+            ->setConstructorArgs(array($amqpConnection))
+            ->getMockForAbstractClass();
+    }
+
+    public function testItExtendsBaseAmqpInterface()
+    {
+        $this->assertInstanceOf('OldSound\RabbitMqBundle\RabbitMq\BaseAmqp', $this->consumer);
+    }
+
+    public function testItImplementsDequeuerInterface()
+    {
+        $this->assertInstanceOf('OldSound\RabbitMqBundle\RabbitMq\DequeuerInterface', $this->consumer);
+    }
+
+    public function testItsIdleTimeoutIsMutable()
+    {
+        $this->assertEquals(0, $this->consumer->getIdleTimeout());
+        $this->consumer->setIdleTimeout(42);
+        $this->assertEquals(42, $this->consumer->getIdleTimeout());
+    }
+
+    public function testForceStopConsumer()
+    {
+        $this->assertAttributeEquals(false, 'forceStop', $this->consumer);
+        $this->consumer->forceStopConsumer();
+        $this->assertAttributeEquals(true, 'forceStop', $this->consumer);
+    }
+}