@@ -239,6 +239,7 @@ |
||
239 | 239 | * -2^31...+2^31 range. |
240 | 240 | * |
241 | 241 | * Use with caution! |
242 | + * @return integer |
|
242 | 243 | */ |
243 | 244 | public function read_php_int() |
244 | 245 | { |
@@ -2,11 +2,11 @@ |
||
2 | 2 | namespace PhpAmqpLib\Wire; |
3 | 3 | |
4 | 4 | use PhpAmqpLib\Exception\AMQPDataReadException; |
5 | +use PhpAmqpLib\Exception\AMQPIOWaitException; |
|
5 | 6 | use PhpAmqpLib\Exception\AMQPInvalidArgumentException; |
6 | 7 | use PhpAmqpLib\Exception\AMQPNoDataException; |
7 | 8 | use PhpAmqpLib\Exception\AMQPOutOfBoundsException; |
8 | 9 | use PhpAmqpLib\Exception\AMQPTimeoutException; |
9 | -use PhpAmqpLib\Exception\AMQPIOWaitException; |
|
10 | 10 | use PhpAmqpLib\Helper\MiscHelper; |
11 | 11 | use PhpAmqpLib\Wire\IO\AbstractIO; |
12 | 12 |
@@ -31,7 +31,7 @@ discard block |
||
31 | 31 | * Floats has some precision issues and so intentionally not supported. |
32 | 32 | * Beware that floats out of PHP_INT_MAX range will be represented in scientific (exponential) notation when casted to string |
33 | 33 | * |
34 | - * @param int|string $x Value to pack |
|
34 | + * @param integer $x Value to pack |
|
35 | 35 | * @param int $bytes Must be multiply of 2 |
36 | 36 | * @return string |
37 | 37 | */ |
@@ -323,7 +323,7 @@ discard block |
||
323 | 323 | } |
324 | 324 | |
325 | 325 | /** |
326 | - * @param int|string $n |
|
326 | + * @param integer $n |
|
327 | 327 | * @return integer[] |
328 | 328 | */ |
329 | 329 | private function splitIntoQuads($n) |
@@ -214,7 +214,7 @@ discard block |
||
214 | 214 | } |
215 | 215 | |
216 | 216 | /** |
217 | - * @param int|float|null $timeout |
|
217 | + * @param integer $timeout |
|
218 | 218 | * @return array|mixed |
219 | 219 | */ |
220 | 220 | public function next_frame($timeout = 0) |
@@ -319,7 +319,7 @@ discard block |
||
319 | 319 | * |
320 | 320 | * @param array $allowed_methods |
321 | 321 | * @param bool $non_blocking |
322 | - * @param int|float|null $timeout |
|
322 | + * @param integer $timeout |
|
323 | 323 | * @throws \PhpAmqpLib\Exception\AMQPOutOfBoundsException |
324 | 324 | * @throws \PhpAmqpLib\Exception\AMQPRuntimeException |
325 | 325 | * @throws \PhpAmqpLib\Exception\AMQPTimeoutException |
@@ -519,7 +519,7 @@ discard block |
||
519 | 519 | /** |
520 | 520 | * Waits for a frame from the server |
521 | 521 | * |
522 | - * @param int|float|null $timeout |
|
522 | + * @param integer $timeout |
|
523 | 523 | * @return array |
524 | 524 | * @throws \Exception |
525 | 525 | * @throws \PhpAmqpLib\Exception\AMQPTimeoutException |
@@ -580,7 +580,7 @@ discard block |
||
580 | 580 | * Waits for a frame from the server destined for a particular channel. |
581 | 581 | * |
582 | 582 | * @param string $channel_id |
583 | - * @param int|float|null $timeout |
|
583 | + * @param integer $timeout |
|
584 | 584 | * @return array |
585 | 585 | */ |
586 | 586 | protected function wait_channel($channel_id, $timeout = 0) |
@@ -1,12 +1,12 @@ |
||
1 | 1 | <?php |
2 | 2 | namespace PhpAmqpLib\Connection; |
3 | 3 | |
4 | -use PhpAmqpLib\Channel\AbstractChannel; |
|
5 | 4 | use PhpAmqpLib\Channel\AMQPChannel; |
5 | +use PhpAmqpLib\Channel\AbstractChannel; |
|
6 | 6 | use PhpAmqpLib\Exception\AMQPConnectionClosedException; |
7 | 7 | use PhpAmqpLib\Exception\AMQPHeartbeatMissedException; |
8 | -use PhpAmqpLib\Exception\AMQPInvalidFrameException; |
|
9 | 8 | use PhpAmqpLib\Exception\AMQPIOException; |
9 | +use PhpAmqpLib\Exception\AMQPInvalidFrameException; |
|
10 | 10 | use PhpAmqpLib\Exception\AMQPNoDataException; |
11 | 11 | use PhpAmqpLib\Exception\AMQPProtocolConnectionException; |
12 | 12 | use PhpAmqpLib\Exception\AMQPRuntimeException; |
@@ -91,7 +91,7 @@ discard block |
||
91 | 91 | |
92 | 92 | /** |
93 | 93 | * @param \PhpAmqpLib\Connection\AbstractConnection $connection |
94 | - * @param null $channel_id |
|
94 | + * @param integer $channel_id |
|
95 | 95 | * @param bool $auto_decode |
96 | 96 | * @param int $channel_rpc_timeout |
97 | 97 | * @throws \Exception |
@@ -1106,7 +1106,7 @@ discard block |
||
1106 | 1106 | * @param $mandatory |
1107 | 1107 | * @param $immediate |
1108 | 1108 | * @param int $ticket |
1109 | - * @return mixed |
|
1109 | + * @return string |
|
1110 | 1110 | */ |
1111 | 1111 | private function pre_publish($exchange, $routing_key, $mandatory, $immediate, $ticket) |
1112 | 1112 | { |
@@ -1430,7 +1430,7 @@ discard block |
||
1430 | 1430 | * Waits for pending acks and nacks from the server. |
1431 | 1431 | * If there are no pending acks, the method returns immediately |
1432 | 1432 | * |
1433 | - * @param int|float $timeout Waits until $timeout value is reached |
|
1433 | + * @param integer $timeout Waits until $timeout value is reached |
|
1434 | 1434 | * @throws \PhpAmqpLib\Exception\AMQPTimeoutException |
1435 | 1435 | * @throws \PhpAmqpLib\Exception\AMQPRuntimeException |
1436 | 1436 | */ |
@@ -1450,7 +1450,7 @@ discard block |
||
1450 | 1450 | * Waits for pending acks, nacks and returns from the server. |
1451 | 1451 | * If there are no pending acks, the method returns immediately. |
1452 | 1452 | * |
1453 | - * @param int|float $timeout If set to value > 0 the method will wait at most $timeout seconds for pending acks. |
|
1453 | + * @param integer $timeout If set to value > 0 the method will wait at most $timeout seconds for pending acks. |
|
1454 | 1454 | * @throws \PhpAmqpLib\Exception\AMQPTimeoutException |
1455 | 1455 | * @throws \PhpAmqpLib\Exception\AMQPRuntimeException |
1456 | 1456 | */ |