1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
<?php
include(__DIR__ . '/config.php');
use PhpAmqpLib\Connection\AMQPStreamConnection;
$connection = new AMQPStreamConnection(HOST, PORT, USER, PASS, VHOST);
$channel = $connection->channel();
$channel->queue_declare('qos_queue', false, true, false, false);
$channel->basic_qos(null, 10000, null);
function process_message($message)
{
$message->ack();
}
$channel->basic_consume('qos_queue', '', false, false, false, false, 'process_message');
while ($channel->is_consuming()) {
// After 10 seconds there will be a timeout exception.
$channel->wait(null, false, 10);
}
|
