Binding object and test

Author: fatmuemoo

RabbitMq/Binding.php

@@ -0,0 +1,159 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: brandon
+ * Date: 6/24/15
+ * Time: 3:49 PM
+ */
+
+namespace OldSound\RabbitMqBundle\RabbitMq;
+
+
+class Binding extends BaseAmqp
+{
+    /**
+     * @var string
+     */
+    protected $exchange;
+
+    /**
+     * @var string
+     */
+    protected $destination;
+
+    /**
+     * @var bool
+     */
+    protected $destinationIsExchange = false;
+
+    /**
+     * @var string
+     */
+    protected $routingKey;
+
+    /**
+     * @var bool
+     */
+    protected $nowait = false;
+
+    /**
+     * @var array
+     */
+    protected $arguments;
+
+    /**
+     * @return string
+     */
+    public function getExchange()
+    {
+        return $this->exchange;
+    }
+
+    /**
+     * @param string $exchange
+     */
+    public function setExchange($exchange)
+    {
+        $this->exchange = $exchange;
+    }
+
+    /**
+     * @return string
+     */
+    public function getDestination()
+    {
+        return $this->destination;
+    }
+
+    /**
+     * @param bool $destination
+     */
+    public function setDestination($destination)
+    {
+        $this->destination = $destination;
+    }
+
+    /**
+     * @return bool
+     */
+    public function getDestinationIsExchange()
+    {
+        return $this->destinationIsExchange;
+    }
+
+    /**
+     * @param string $destinationIsExchange
+     */
+    public function setDestinationIsExchange($destinationIsExchange)
+    {
+        $this->destinationIsExchange = $destinationIsExchange;
+    }
+
+    /**
+     * @return string
+     */
+    public function getRoutingKey()
+    {
+        return $this->routingKey;
+    }
+
+    /**
+     * @param string $routingKey
+     */
+    public function setRoutingKey($routingKey)
+    {
+        $this->routingKey = $routingKey;
+    }
+
+    /**
+     * @return boolean
+     */
+    public function isNowait()
+    {
+        return $this->nowait;
+    }
+
+    /**
+     * @param boolean $nowait
+     */
+    public function setNowait($nowait)
+    {
+        $this->nowait = $nowait;
+    }
+
+    /**
+     * @return array
+     */
+    public function getArguments()
+    {
+        return $this->arguments;
+    }
+
+    /**
+     * @param array $arguments
+     */
+    public function setArguments($arguments)
+    {
+        $this->arguments = $arguments;
+    }
+
+
+    /**
+     * create bindings
+     *
+     * @return void
+     */
+    public function setupFabric()
+    {
+        $method  = ($this->destinationIsExchange) ? 'exchange_bind' : 'queue_bind';
+        $channel = $this->getChannel();
+        call_user_func(
+            array($channel, $method),
+            $this->destination,
+            $this->exchange,
+            $this->routingKey,
+            $this->nowait,
+            $this->arguments
+        );
+    }
+}

Tests/RabbitMq/BindingTest.php

@@ -0,0 +1,83 @@
+<?php
+
+namespace OldSound\RabbitMqBundle\Tests\RabbitMq;
+
+
+use OldSound\RabbitMqBundle\RabbitMq\Binding;
+
+class BindingTest extends \PHPUnit_Framework_TestCase
+{
+
+    protected function getBinding($amqpConnection, $amqpChannel)
+    {
+        return new Binding($amqpConnection, $amqpChannel);
+    }
+
+    /**
+     * @return \PHPUnit_Framework_MockObject_MockObject
+     */
+    protected function prepareAMQPConnection()
+    {
+        return $this->getMockBuilder('\PhpAmqpLib\Connection\AMQPConnection')
+            ->disableOriginalConstructor()
+            ->getMock();
+    }
+
+    protected function prepareAMQPChannel()
+    {
+        return $this->getMockBuilder('\PhpAmqpLib\Channel\AMQPChannel')
+            ->disableOriginalConstructor()
+            ->getMock();
+    }
+
+    public function testQueueBind()
+    {
+        $ch = $this->prepareAMQPChannel();
+        $con = $this->prepareAMQPConnection();
+
+        $source = 'example_source';
+        $destination = 'example_destination';
+        $key = 'example_key';
+        $ch->expects($this->once())
+            ->method('queue_bind')
+            ->will($this->returnCallback(function ($d, $s, $k, $n, $a) use ($destination, $source, $key) {
+                \PHPUnit_Framework_Assert::assertSame($destination, $d);
+                \PHPUnit_Framework_Assert::assertSame($source, $s);
+                \PHPUnit_Framework_Assert::assertSame($key, $k);
+                \PHPUnit_Framework_Assert::assertFalse($n);
+                \PHPUnit_Framework_Assert::assertNull($a);
+            }));
+
+        $binding = $this->getBinding($con, $ch);
+        $binding->setExchange($source);
+        $binding->setDestination($destination);
+        $binding->setRoutingKey($key);
+        $binding->setupFabric();
+    }
+
+    public function testExhangeBind()
+    {
+        $ch = $this->prepareAMQPChannel();
+        $con = $this->prepareAMQPConnection();
+
+        $source = 'example_source';
+        $destination = 'example_destination';
+        $key = 'example_key';
+        $ch->expects($this->once())
+            ->method('exchange_bind')
+            ->will($this->returnCallback(function ($d, $s, $k, $n, $a) use ($destination, $source, $key) {
+                \PHPUnit_Framework_Assert::assertSame($destination, $d);
+                \PHPUnit_Framework_Assert::assertSame($source, $s);
+                \PHPUnit_Framework_Assert::assertSame($key, $k);
+                \PHPUnit_Framework_Assert::assertFalse($n);
+                \PHPUnit_Framework_Assert::assertNull($a);
+            }));
+
+        $binding = $this->getBinding($con, $ch);
+        $binding->setExchange($source);
+        $binding->setDestination($destination);
+        $binding->setRoutingKey($key);
+        $binding->setDestinationIsExchange(true);
+        $binding->setupFabric();
+    }
+}