skolodyazhnyy / butter-amqplib

src/AMQP091/Connection.php

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;

src/AMQP091/Channel.php

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;
     }