@@ -399,7 +399,7 @@ |
||
| 399 | 399 | } |
| 400 | 400 | |
| 401 | 401 | /** |
| 402 | - * @return string |
|
| 402 | + * @return integer |
|
| 403 | 403 | */ |
| 404 | 404 | public function getStatus() |
| 405 | 405 | { |
@@ -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 | } |
@@ -62,7 +62,7 @@ |
||
| 62 | 62 | private $capabilities = []; |
| 63 | 63 | |
| 64 | 64 | /** |
| 65 | - * @param Url|string $url |
|
| 65 | + * @param Url $url |
|
| 66 | 66 | * @param WireInterface $wire |
| 67 | 67 | * @param AuthenticatorInterface $authenticator |
| 68 | 68 | */ |
@@ -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; |
@@ -38,8 +38,8 @@ |
||
| 38 | 38 | /** |
| 39 | 39 | * Initialize default logger. |
| 40 | 40 | * |
| 41 | - * @param int|float $connectionTimeout |
|
| 42 | - * @param int|float $readingTimeout |
|
| 41 | + * @param integer $connectionTimeout |
|
| 42 | + * @param integer $readingTimeout |
|
| 43 | 43 | */ |
| 44 | 44 | public function __construct($connectionTimeout = 30, $readingTimeout = 1) |
| 45 | 45 | { |
@@ -136,7 +136,7 @@ |
||
| 136 | 136 | |
| 137 | 137 | /** |
| 138 | 138 | * @param string $key |
| 139 | - * @param mixed $default |
|
| 139 | + * @param integer $default |
|
| 140 | 140 | * |
| 141 | 141 | * @return mixed |
| 142 | 142 | */ |
@@ -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 | } |