|
@@ -130,8 +130,7 @@ discard block |
|
|
block discarded – undo |
|
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 |
|
|
block discarded – undo |
|
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
|
} |
Please login to merge, or discard this patch.