php-amqplib

1зной

2ответ

Я пытаюсь отправить запрос на AMQP, застрял в том, чтобы добавить заголовок к сообщению запроса, то внизу обертка мы имеем $message = ‘{"empId": ‘.$empId.', “empName”:”my name"}’; $resData = $rpcClie

1зной

1ответ

Отправить массив через RabbitMQ

Как я могу отправить массив сообщений с помощью RabbitMQ? Я не хочу отправлять каждое сообщение отдельно. Для examlple: ch.publish(ex, '', new Buffer('hello world')); Как я мог бы использовать somet

0зной

1ответ

PHP Ampqlib Потребительские компьютеры: ошибка чтения данных. Получено 0 вместо ожидаемых 1 байт

OK Это часть сценария командной строки Symfony2. Пока сценарий ждет, он умирает с этим Исключением. [PhpAmqpLib\Exception\AMQPRuntimeException] Error reading data. Received 0 instead of expected

2зной

1ответ

Как выполнить блокировку basic_get коллировать с videlalvaro/PHP-amqplib

Я использую https://github.com/videlalvaro/php-amqplib сделать некоторые RabbitMQ работы: Я пытаюсь создать блокирующую версию basic_get, (или версию basic_consume что я могу многократно вызывать и по

3зной

3ответ

Как использовать задержанную очередь сообщений RabbitMQ из PHP?

Я пытаюсь использовать Delayed Message Queue для RabbitMQ с PHP, но мои сообщения просто исчезают. я объявляю обмен со следующим кодом: $this->channel->exchange_declare( 'delay', 'x-delayed-m

1зной

1ответ

rabbitmq, неспособный отправить сообщение в определенную очередь

Я пытаюсь доставить сообщение на обмен, а затем в определенную очередь. $conn = new AMQPConnection(RABBITMQ_NODE_IP_ADDRESS, RABBITMQ_PORT, RABBITMQ_USERNAME, RABBITMQ_PASSWORD, RABBITMQ_VHOST);