@@ -130,8 +130,7 @@ discard block |
||
130 | 130 | /** @var ChannelFlowOk $frame */ |
131 | 131 | $frame = $this->wire->wait($this->id, ChannelFlowOk::class); |
132 | 132 | |
133 | - $this->status = $frame->isActive() ? self::STATUS_READY : |
|
134 | - self::STATUS_INACTIVE; |
|
133 | + $this->status = $frame->isActive() ? self::STATUS_READY : self::STATUS_INACTIVE; |
|
135 | 134 | |
136 | 135 | return $this; |
137 | 136 | } |
@@ -312,8 +311,7 @@ discard block |
||
312 | 311 | */ |
313 | 312 | public function reject($deliveryTag, $requeue = true, $multiple = false) |
314 | 313 | { |
315 | - $multiple ? $this->wire->send(new BasicNack($this->id, $deliveryTag, $multiple, $requeue)) : |
|
316 | - $this->wire->send(new BasicReject($this->id, $deliveryTag, $requeue)); |
|
314 | + $multiple ? $this->wire->send(new BasicNack($this->id, $deliveryTag, $multiple, $requeue)) : $this->wire->send(new BasicReject($this->id, $deliveryTag, $requeue)); |
|
317 | 315 | |
318 | 316 | return $this; |
319 | 317 | } |