RabbitMQ: Как сохранить сообщение в очереди?

Question

[Александр]

Доброго времени суток! Есть необходимость реализации обмена сообщениями при помощи RabbitMQ, с использованием типа "topic". Написал код, как приведено в примере на официальном сайте www.rabbitmq.com/tutorials/tutorial-five-php.html, все замечательно работает. Но есть одно "но", а именно - если отправлять сообщение в тот момент, когда подписчик не запущен, то сообщения в очереди не накапливаются, а просто пропадают и до подписчика в конечном итоге не попадают, но если подписчик активен, то и сообщения нормально доходят.

Как же все-таки заставить код из примера накапливать сообщения в очереди?

Заранее спасибо!

Answer 1

[Сергей]

Если я понимаю верно, то при создании очереди (queue_declare) в качестве имени указывается пустая строка, на что RabbitMQ создаёт для неё случайное имя и добавляет флаг exclusive, вследствие чего очередь удаляется при закрытии подключения клиентом. Попробуйте дать собственное имя для очереди и посмотрите параметры вызова этого метода.

Comments

[Александр]

Попробовал задать жестко имя очереди, и поиграться с параметром exclusive. В итоге выскакивает такая вот ошибка:

Fatal error: Uncaught exception 'PhpAmqpLib\Exception\AMQPProtocolChannelException' with message 'PRECONDITION_FAILED - inequivalent arg 'durable' for queue 'esb24_4epnhdjnxd7fxew49yd7mqegnwn461ty' in vhost '/': received 'false' but current is 'true'' in /var/www/rexchange/esb24/classes/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Channel/AMQPChannel.php:188 Stack trace: #0 [internal function]: PhpAmqpLib\Channel\AMQPChannel->channel_close(Object(PhpAmqpLib\Wire\AMQPReader)) #1 /var/www/rexchange/esb24/classes/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Channel/AbstractChannel.php(199): call_user_func(Array, Object(PhpAmqpLib\Wire\AMQPReader)) #2 /var/www/rexchange/esb24/classes/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Channel/AbstractChannel.php(341): PhpAmqpLib\Channel\AbstractChannel->dispatch('20,40', '???PRECONDITION...', NULL) #3 /var/www/rexchange/esb24/classes/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Channel/AMQPChannel.php(640): PhpAmqpLib\Channel\AbstractChannel->wait(Array) #4 /var/www/rexchange/esb24/classes/rabb in /var/www/rexchange/esb24/classes/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Channel/AMQPChannel.php on line 188

[Сергей]

sanchez161: в каком-то месте Вы создаёте очередь с durable=true, а потом с durable=false, такого делать нельзя (inequivalent arg 'durable' for queue received 'false' but current is 'true'). Если хотите сменить параметры придётся удалить уже существующую очередь с таким именем.

[Александр]

Сергей: удалил очереди и создал заново с параметром durable=true, но проблема сохраняется. Наверняка проблема в каком-нибудь одном параметре...но в каком...

[Сергей]

Александр: Исходный код либы, вероятно, самый лучший подсказчик - https://github.com/php-amqplib/php-amqplib/blob/ma...