Пример неблокирующего php-amqplib выдает предупреждения
Я пытаюсь использовать библиотеку videlalvaro/php-amqplib для связи AMQP, но не могу заставить работать неблокирующую версию. При запуске demo/amqp_consumer_non_blocking.php постоянно отображается следующее сообщение об ошибке:
PHP Warning: stream_select(): supplied argument is not a valid stream resource in RabbitMQ/test/amqp_consumer_non_blocking.php on line 86
PHP Stack trace:
PHP 1. {main}() RabbitMQ/test/amqp_consumer_non_blocking.php:0
PHP 2. stream_select(*uninitialized*, *uninitialized*, *uninitialized*, *uninitialized*) RabbitMQ/test/amqp_consumer_non_blocking.php:86
Подавление этого сообщения символом @ ослабляет ошибку, но я все еще не могу заставить его что-либо показать.
Я предполагаю, что отправляю ему сообщение правильно: я использую веб-интерфейс и просто публикую сообщение прямо в очереди, но, как я уже сказал, я ничего не получаю в своем неблокирующем цикле.
Выполнение того же процесса с блокирующей демонстрацией (demo/amqp_consumer.php) работает, как и ожидалось.
Кто-нибудь еще имел такие проблемы или они могут направить меня к некоторым возможным решениям? Благодарю.