Articles of rabbitmq

Установка RabbitMQ PHP: Неустранимая ошибка: Class 'AMQPConnection' не найден

Я уже установил RabbitMQ на свой сервер, и все отлично работает с ним. Я уже пытался отправлять и получать сообщения в очереди с помощью Java-клиента, и все прошло отлично. Теперь мне нужно установить PHP RabbitMQ-клиент, потому что я хочу передать Java-программу с веб-страницей PHP, но на этот раз мне не повезло. Я уже выполнил шаги […]

Где я могу найти документацию php-amqp?

Мы планируем использовать RabbitMQ с PHP, и мы решили пойти с php–amqp, потому что он поддерживает PHP 5.2. Единственная проблема – я не могу найти подходящую документацию для этой библиотеки PECL

Документирование сообщений AMQP

Какова была бы лучшая практика для документирования сообщений AMQP? Моя компания разрабатывает несколько отдельных внутренних приложений (отдельными командами), которые общаются друг с другом с помощью асинхронного обмена сообщениями RabbitMQ. В каждом типе связи используется формат пользовательских сообщений, например, событие, опубликованное «документ»: $documentPublishedEvent = array( 'document_type' => 'invoice', 'published_on' => '2012-02-15', 'published_by' => 'jim', ); Формат […]

ошибка rabbitmq при подключении

Я получил эту ошибку, когда пытаюсь подключиться с помощью php-amqp: Fatal error: Class 'AMQPConnection' не найден в $credentials =array('host' => 'localhost','port' => 5672); $cnn = new AMQPConnection($credentials); $cnn->connect();

PHPUnit RabbitMQ: написать тест для создания функции соединения

Я столкнулся со следующей проблемой. Я написал функцию, которая создает объект соединения (AMQPConnection) с заданными параметрами. Теперь я хочу написать соответствующий модульный тест. Я просто не знаю, как это сделать без использования брокера RabbitMQ. Вот эта функция: public function getConnection($hostKey, array $params) { $connection = null; try { $connection = new AMQPConnection( $params['host'], $params['port'], $params['username'], […]

AMQPRuntimeException: ошибка чтения данных. Получено 0 вместо ожидаемых 7 байт

Он работал, но теперь он больше не работает! Я использую php–amqplib и RabbitMQ. Он показывает эту ошибку: (перетащите снимок экрана на новую вкладку, если это не ясно) когда я пытаюсь создать новое соединение AMQP: $connection = new AMQPConnection('localhost', 5672, 'username', 'password'); Код внутри библиотеки, вызывающий эту ошибку: public function read($n) { $res = ''; $read […]

Многопользовательская одна очередь

Можно ли заставить нескольких потребителей делиться одной очередью в RabbitMQ? В настоящее время я использую эту библиотеку php для работы с RabbitMQ, от того, что я наблюдаю, хотя у меня есть 2 одинаковых экземпляра запускаемого пользовательского скрипта, но только один ответит на переданное сообщение …

Получение сообщений из очереди (ов) RabbitMQ

Я ищу, чтобы реализовать RabbitMQ в моем приложении PHP, и использую расширение php–amqp. Мой единственный вопрос в том, как я могу легко запросить возврат содержимого очереди в PHP? php-amqp, похоже, не позволяет мне это делать. Если я ошибаюсь, пожалуйста, помогите мне здесь 🙂

rabbitmq AMQP :: потреблять ()

Функция AMQP consume () – это функция блокировки с обратным вызовом, возможно ли установить тайм-аут для функции потребления (), поэтому через определенное время он больше не блокируется и выполнение кода завершается?

как установить php amqp в ubuntu

Я пытаюсь установить amqp для php (Интеграция PHP с RabbitMQ), используя этот http://code.google.com/p/php-amqp/ . после запуска phpize && ./configure –with-amqp && make && sudo make install он дает такую ​​ошибку Не удается найти config.m4. Убедитесь, что вы запустили '/ usr / bin / phpize' в исходной директории верхнего уровня модуля Пожалуйста, помогите мне, моя среда […]