@@ 1271-1284 (lines=14) @@ | ||
1268 | * @throws \PhpAmqpLib\Exception\AMQPTimeoutException if the specified operation timeout was exceeded |
|
1269 | * @return mixed |
|
1270 | */ |
|
1271 | public function basic_qos($prefetch_size, $prefetch_count, $a_global) |
|
1272 | { |
|
1273 | list($class_id, $method_id, $args) = $this->protocolWriter->basicQos( |
|
1274 | $prefetch_size, |
|
1275 | $prefetch_count, |
|
1276 | $a_global |
|
1277 | ); |
|
1278 | ||
1279 | $this->send_method_frame(array($class_id, $method_id), $args); |
|
1280 | ||
1281 | return $this->wait(array( |
|
1282 | $this->waitHelper->get_wait('basic.qos_ok') |
|
1283 | ), false, $this->channel_rpc_timeout); |
|
1284 | } |
|
1285 | ||
1286 | /** |
|
1287 | * Confirms QoS request |
|
@@ 1300-1308 (lines=9) @@ | ||
1297 | * @throws \PhpAmqpLib\Exception\AMQPTimeoutException if the specified operation timeout was exceeded |
|
1298 | * @return mixed |
|
1299 | */ |
|
1300 | public function basic_recover($requeue = false) |
|
1301 | { |
|
1302 | list($class_id, $method_id, $args) = $this->protocolWriter->basicRecover($requeue); |
|
1303 | $this->send_method_frame(array($class_id, $method_id), $args); |
|
1304 | ||
1305 | return $this->wait(array( |
|
1306 | $this->waitHelper->get_wait('basic.recover_ok') |
|
1307 | ), false, $this->channel_rpc_timeout); |
|
1308 | } |
|
1309 | ||
1310 | /** |
|
1311 | * Confirm the requested recover |