thecodingmachine / oo-amqp-client

src/Objects/Exchange.php

Doc Comments +3 added lines, -1 removed lines

@@ -86,7 +86,6 @@ 
     /**
      * Set the to (Binding).
      *
-     * @param Client $to
      * @param string $name
      * @param string $type direct, topic, headers or fanout
      */
@@ -292,6 +291,9 @@ 
         }
     }
 
+    /**
+     * @param string $routingKey
+     */
     public function publish(Message $message, $routingKey, $mandatory = false,
                             $immediate = false,
                             $ticket = null)

src/Objects/Queue.php

Spacing +1 added lines, -1 removed lines

@@ -539,7 +539,7 @@
                                     $consumer->isNoAck(),
                                     $consumer->isExclusive(),
                                     $consumer->isNoWait(),
-                                    function (AMQPMessage $msg) use ($consumer) {
+                                    function(AMQPMessage $msg) use ($consumer) {
                                         $consumer->callback($msg);
                                     },
                                     $consumer->getTicket(),

Doc Comments +1 added lines, -2 removed lines

@@ -133,7 +133,6 @@ 
     /**
      * Set the source (Binding).
      *
-     * @param Binding             $source
      * @param string              $name
      * @param ConsumerInterface[] $consumers
      */
@@ -324,7 +323,7 @@ 
     /**
      * Get RabbitMq specific parameter : dead letter queue.
      *
-     * @return Queue
+     * @return Exchange
      */
     public function getDeadLetterExchanger()
     {

tests/ClientTest.php

Spacing +1 added lines, -1 removed lines

@@ -161,7 +161,7 @@
     {
         $client = $this->makeClient();
         $queue = new Queue($client, 'test_direct_queue', [
-            new Consumer(function (AMQPMessage $msg) {
+            new Consumer(function(AMQPMessage $msg) {
                 $this->msgReceived = $msg;
             }, new NullLogger())
         ]);

src/Client.php

Unused Use Statements -1 removed lines

@@ -3,7 +3,6 @@
 namespace Mouf\AmqpClient;
 
 use PhpAmqpLib\Connection\AbstractConnection;
-use PhpAmqpLib\Connection\AMQPSocketConnection;
 use PhpAmqpLib\Connection\AMQPStreamConnection;
 use PhpAmqpLib\Channel\AMQPChannel;
 use Mouf\AmqpClient\Exception\ConnectionException;

Spacing +3 added lines, -3 removed lines

@@ -308,7 +308,7 @@ 
                         $this->connection_timeout,
                         $this->read_write_timeout,
                         $this->context,
-                        $this->keepalive ,
+                        $this->keepalive,
                         $this->heartbeat
                     );
                 } else {
@@ -325,7 +325,7 @@ 
                         $this->connection_timeout,
                         $this->read_write_timeout,
                         $this->context,
-                        $this->keepalive ,
+                        $this->keepalive,
                         $this->heartbeat
                     );
                 }
@@ -359,7 +359,7 @@ 
      */
     public function getQueues()
     {
-        return array_filter($this->rabbitMqObjects, function (RabbitMqObjectInterface $object) {
+        return array_filter($this->rabbitMqObjects, function(RabbitMqObjectInterface $object) {
             return $object instanceof QueueInterface;
         });
     }