Amqplib нет сообщения об ошибке

Я использую C-компилированную библиотеку для кролика AMQP.
Пытаясь получить сообщения из очереди без подтверждения, я получаю только первые три сообщения при обратном вызове.
Мониторинг сервера показывает, что 3 сообщения были получены без подтверждения.

Если я использую php-amqplib, я получаю все сообщения из очереди без подтверждения во время сеанса.

Код как:

$cnn = new AMQPConnection();
$cnn->setLogin('guest');
$cnn->setPassword('guest');

if ($cnn->connect()) {
} else {
die("Error");
}

$channel = new AMQPChannel($cnn);
$exchange = new AMQPExchange($channel);
$exchange->setName('test');
$exchange->setType(AMQP_EX_TYPE_TOPIC);
$exchange->setFlags(AMQP_DURABLE | AMQP_AUTODELETE | AMQP_PASSIVE);

try {
$exchange->declareExchange();
} catch (Exception $e) {
echo 'Error: '.$e->getMessage();
die(0);
}

$q = new AMQPQueue($channel);
$q->setName('queue');
$q->setFlags(AMQP_DURABLE | AMQP_PASSIVE);
$cnt = $q->declareQueue();

$q->bind($exchange->getName(),'token');

$cb = function(AMQPEnvelope $params, AMQPQueue $queue) {
print_r($params->getBody());
echo "\n";
};

while (true) {
$q->consume($cb);
}

$cnn->disconnect();

0

Решение

Задача ещё не решена.

Другие решения

Других решений пока нет …

По вопросам рекламы [email protected]