@@ -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\AMQPRuntimeException; |
12 | 12 | use PhpAmqpLib\Exception\AMQPSocketException; |
@@ -138,7 +138,7 @@ discard block |
||
138 | 138 | } |
139 | 139 | |
140 | 140 | /** |
141 | - * @return string |
|
141 | + * @return integer |
|
142 | 142 | */ |
143 | 143 | public function getChannelId() |
144 | 144 | { |
@@ -220,7 +220,7 @@ discard block |
||
220 | 220 | } |
221 | 221 | |
222 | 222 | /** |
223 | - * @param int|float|null $timeout |
|
223 | + * @param integer $timeout |
|
224 | 224 | * @return array|mixed |
225 | 225 | */ |
226 | 226 | public function next_frame($timeout = 0) |
@@ -325,7 +325,7 @@ discard block |
||
325 | 325 | * |
326 | 326 | * @param array $allowed_methods |
327 | 327 | * @param bool $non_blocking |
328 | - * @param int|float|null $timeout |
|
328 | + * @param integer $timeout |
|
329 | 329 | * @throws \PhpAmqpLib\Exception\AMQPOutOfBoundsException |
330 | 330 | * @throws \PhpAmqpLib\Exception\AMQPRuntimeException |
331 | 331 | * @throws \PhpAmqpLib\Exception\AMQPTimeoutException |
@@ -97,7 +97,7 @@ discard block |
||
97 | 97 | * @param AbstractConnection $connection |
98 | 98 | * @param int|null $channel_id |
99 | 99 | * @param bool $auto_decode |
100 | - * @param int|float $channel_rpc_timeout |
|
100 | + * @param integer $channel_rpc_timeout |
|
101 | 101 | * @throws \Exception |
102 | 102 | */ |
103 | 103 | public function __construct($connection, $channel_id = null, $auto_decode = true, $channel_rpc_timeout = 0) |
@@ -334,7 +334,7 @@ discard block |
||
334 | 334 | * Grants access to server resources |
335 | 335 | * |
336 | 336 | * @param AMQPReader $reader |
337 | - * @return string |
|
337 | + * @return integer |
|
338 | 338 | */ |
339 | 339 | protected function access_request_ok($reader) |
340 | 340 | { |
@@ -1095,7 +1095,7 @@ discard block |
||
1095 | 1095 | * @param bool $mandatory |
1096 | 1096 | * @param bool $immediate |
1097 | 1097 | * @param int $ticket |
1098 | - * @return mixed |
|
1098 | + * @return string |
|
1099 | 1099 | */ |
1100 | 1100 | private function pre_publish($exchange, $routing_key, $mandatory, $immediate, $ticket) |
1101 | 1101 | { |
@@ -1421,7 +1421,7 @@ discard block |
||
1421 | 1421 | * Waits for pending acks and nacks from the server. |
1422 | 1422 | * If there are no pending acks, the method returns immediately |
1423 | 1423 | * |
1424 | - * @param int|float $timeout Waits until $timeout value is reached |
|
1424 | + * @param integer $timeout Waits until $timeout value is reached |
|
1425 | 1425 | * @throws \PhpAmqpLib\Exception\AMQPTimeoutException |
1426 | 1426 | * @throws \PhpAmqpLib\Exception\AMQPRuntimeException |
1427 | 1427 | */ |
@@ -1441,7 +1441,7 @@ discard block |
||
1441 | 1441 | * Waits for pending acks, nacks and returns from the server. |
1442 | 1442 | * If there are no pending acks, the method returns immediately. |
1443 | 1443 | * |
1444 | - * @param int|float $timeout If set to value > 0 the method will wait at most $timeout seconds for pending acks. |
|
1444 | + * @param integer $timeout If set to value > 0 the method will wait at most $timeout seconds for pending acks. |
|
1445 | 1445 | * @throws \PhpAmqpLib\Exception\AMQPTimeoutException |
1446 | 1446 | * @throws \PhpAmqpLib\Exception\AMQPRuntimeException |
1447 | 1447 | */ |
@@ -53,7 +53,7 @@ discard block |
||
53 | 53 | /** |
54 | 54 | * @param string|null $str |
55 | 55 | * @param AbstractIO $io |
56 | - * @param int|float $timeout |
|
56 | + * @param integer $timeout |
|
57 | 57 | */ |
58 | 58 | public function __construct($str, AbstractIO $io = null, $timeout = 0) |
59 | 59 | { |
@@ -261,7 +261,7 @@ discard block |
||
261 | 261 | * -2^31...+2^31 range. |
262 | 262 | * |
263 | 263 | * Use with caution! |
264 | - * @return int|string |
|
264 | + * @return integer |
|
265 | 265 | */ |
266 | 266 | public function read_php_int() |
267 | 267 | { |
@@ -4,7 +4,6 @@ |
||
4 | 4 | |
5 | 5 | use PhpAmqpLib\Exception\AMQPDataReadException; |
6 | 6 | use PhpAmqpLib\Exception\AMQPInvalidArgumentException; |
7 | -use PhpAmqpLib\Exception\AMQPIOWaitException; |
|
8 | 7 | use PhpAmqpLib\Exception\AMQPNoDataException; |
9 | 8 | use PhpAmqpLib\Exception\AMQPOutOfBoundsException; |
10 | 9 | use PhpAmqpLib\Exception\AMQPTimeoutException; |
@@ -19,7 +19,7 @@ |
||
19 | 19 | /** |
20 | 20 | * @param int $reply_code |
21 | 21 | * @param string $reply_text |
22 | - * @param array $method_sig |
|
22 | + * @param integer[] $method_sig |
|
23 | 23 | */ |
24 | 24 | public function __construct($reply_code, $reply_text, $method_sig) |
25 | 25 | { |