skolodyazhnyy / butter-amqplib

src/AMQP091/Channel.php

Doc Comments +1 added lines, -1 removed lines

@@ -399,7 +399,7 @@
     }
 
     /**
-     * @return string
+     * @return integer
      */
     public function getStatus()
     {

Spacing +2 added lines, -4 removed lines

@@ -130,8 +130,7 @@ 
         /** @var ChannelFlowOk $frame */
         $frame = $this->wire->wait($this->id, ChannelFlowOk::class);
 
-        $this->status = $frame->isActive() ? self::STATUS_READY :
-            self::STATUS_INACTIVE;
+        $this->status = $frame->isActive() ? self::STATUS_READY : self::STATUS_INACTIVE;
 
         return $this;
     }
@@ -312,8 +311,7 @@ 
      */
     public function reject($deliveryTag, $requeue = true, $multiple = false)
     {
-        $multiple ? $this->wire->send(new BasicNack($this->id, $deliveryTag, $multiple, $requeue)) :
-            $this->wire->send(new BasicReject($this->id, $deliveryTag, $requeue));
+        $multiple ? $this->wire->send(new BasicNack($this->id, $deliveryTag, $multiple, $requeue)) : $this->wire->send(new BasicReject($this->id, $deliveryTag, $requeue));
 
         return $this;
     }

src/AMQP091/Connection.php

Doc Comments +1 added lines, -1 removed lines

@@ -62,7 +62,7 @@
     private $capabilities = [];
 
     /**
-     * @param Url|string             $url
+     * @param Url             $url
      * @param WireInterface          $wire
      * @param AuthenticatorInterface $authenticator
      */

Unused Use Statements -1 removed lines

@@ -6,7 +6,6 @@
 use ButterAMQP\Exception\AMQPException;
 use ButterAMQP\Exception\InvalidChannelNumberException;
 use ButterAMQP\AMQP091\Framing\Frame;
-use ButterAMQP\AMQP091\Framing\Heartbeat;
 use ButterAMQP\AMQP091\Framing\Method\ConnectionBlocked;
 use ButterAMQP\AMQP091\Framing\Method\ConnectionClose;
 use ButterAMQP\AMQP091\Framing\Method\ConnectionCloseOk;