@@ -5,7 +5,6 @@ |
||
| 5 | 5 | use ButterAMQP\Exception\AMQPException; |
| 6 | 6 | use ButterAMQP\Exception\InvalidChannelNumberException; |
| 7 | 7 | use ButterAMQP\Framing\Frame; |
| 8 | -use ButterAMQP\Framing\Heartbeat; |
|
| 9 | 8 | use ButterAMQP\Framing\Method\ConnectionBlocked; |
| 10 | 9 | use ButterAMQP\Framing\Method\ConnectionClose; |
| 11 | 10 | use ButterAMQP\Framing\Method\ConnectionCloseOk; |
@@ -131,8 +131,7 @@ discard block |
||
| 131 | 131 | $frame = $this->send(new ChannelFlow($this->id, $active)) |
| 132 | 132 | ->wait(ChannelFlowOk::class); |
| 133 | 133 | |
| 134 | - $this->status = $frame->isActive() ? self::STATUS_READY : |
|
| 135 | - self::STATUS_INACTIVE; |
|
| 134 | + $this->status = $frame->isActive() ? self::STATUS_READY : self::STATUS_INACTIVE; |
|
| 136 | 135 | |
| 137 | 136 | return $this; |
| 138 | 137 | } |
@@ -307,8 +306,7 @@ discard block |
||
| 307 | 306 | */ |
| 308 | 307 | public function reject($deliveryTag, $requeue = true, $multiple = false) |
| 309 | 308 | { |
| 310 | - $multiple ? $this->send(new BasicNack($this->id, $deliveryTag, $multiple, $requeue)) : |
|
| 311 | - $this->send(new BasicReject($this->id, $deliveryTag, $requeue)); |
|
| 309 | + $multiple ? $this->send(new BasicNack($this->id, $deliveryTag, $multiple, $requeue)) : $this->send(new BasicReject($this->id, $deliveryTag, $requeue)); |
|
| 312 | 310 | |
| 313 | 311 | return $this; |
| 314 | 312 | } |