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