@@ -131,8 +131,7 @@ discard block |
||
| 131 | 131 | $frame = $this->send(new ChannelFlow($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 | } |
@@ -305,8 +304,7 @@ discard block |
||
| 305 | 304 | */ |
| 306 | 305 | public function reject($deliveryTag, $requeue = true, $multiple = false) |
| 307 | 306 | { |
| 308 | - $multiple ? $this->send(new BasicNack($deliveryTag, $multiple, $requeue)) : |
|
| 309 | - $this->send(new BasicReject($deliveryTag, $requeue)); |
|
| 307 | + $multiple ? $this->send(new BasicNack($deliveryTag, $multiple, $requeue)) : $this->send(new BasicReject($deliveryTag, $requeue)); |
|
| 310 | 308 | |
| 311 | 309 | return $this; |
| 312 | 310 | } |
@@ -107,7 +107,6 @@ |
||
| 107 | 107 | */ |
| 108 | 108 | public static function subset($data, $offset = 0, $length = null) |
| 109 | 109 | { |
| 110 | - return self::$isMultibyteAvailable ? mb_substr($data, $offset, $length, 'ASCII') : |
|
| 111 | - substr($data, $offset, $length); |
|
| 110 | + return self::$isMultibyteAvailable ? mb_substr($data, $offset, $length, 'ASCII') : substr($data, $offset, $length); |
|
| 112 | 111 | } |
| 113 | 112 | } |