php-amqplib

0зной

2ответ

fwrite() ожидает, что параметр 1 будет ресурсом, целое число, указанное в PhpAMQP, когда доступ переместился из локальной переменной в поле объекта, наследующего от \ Thread

При использовании соединения в качестве поля класса, наследующего от \ Thread, я получаю следующая ошибка при вызове $ this-> connection-> channel(): Предупреждение: fwrite() ожидает, что параметр 1 б

0зной

1ответ

Как остановить Rabbitmq Consumer после обработки 10 сообщений?

Я работал с потребителем из crontab и обрабатывал все сообщения один за другим, есть ли способ использовать только 10 или 20 сообщений, а затем останавливаться на потребителе. Так что в следующий раз

1зной

1ответ

Как установить Потребитель начал один раз и продолжается вечно непрерывно.

Я очень новичок в RabbitMQ и использую RabbitMQ 3.5.3, Erlang R14B04 и библиотеку Альваро Видела (https://github.com/videlalvaro/php-amqplib) для очередей в RabbitMQ. Мне нужно постоянно поддерживать

1зной

1ответ

RabbitMQ (PHP) Можно ли проверить, есть ли прослушиватель канала перед публикацией?

с использованием php-amqplib, можно ли проверить, есть ли прослушиватель канала перед отправкой сообщения. Идея этого заключается в том, чтобы публиковать сообщение только в том случае, если есть толь