0
Я использую RabbitMQ 3.6.6 с помощью докера изображения «RabbitMQ: 3»RabbitMQ новый потребитель вешает
Всякий раз, когда я добавить новый потребитель в мою очередь RabbitMQ она свисает из любой точки мира 10 секунд 10 часов.
Ниже приведен пример кода, используемого для получения ошибки. Я также получаю эту ошибку в Go. Так что это не зависит от библиотеки.
<?php
include(__DIR__."/vendor/autoload.php");
print "Start" . PHP_EOL;
$connection = new \PhpAmqpLib\Connection\AMQPStreamConnection('xxxx', 5697, 'guest', 'guest');
$channel = $connection->channel();
$callback = function($msg) {
echo " [x] Received ", $msg->body, "\n";
};
$channel->basic_consume('repositories', '', false, false, false, false, $callback);
while(count($channel->callbacks)) {
$channel->wait();
}
Когда я смотрю на журналы я вижу
=INFO REPORT==== 31-Jan-2017::21:14:33 ===
accepting AMQP connection <0.891.0> (10.32.0.1:54216 -> 10.44.0.3:5672)
=INFO REPORT==== 31-Jan-2017::21:14:34 ===
accepting AMQP connection <0.902.0> (10.32.0.1:54247 -> 10.44.0.3:5672)
Когда я list_consumer во время через rabbitmqctl я вижу потребителя в списке, пока сообщения не обрабатываются им.