тут пример: https://www.rabbitmq.com/tutorials/tutorial-five-php.html но у меня он не завёлся.
В этом примере выше код такой:
$channel->exchange_declare('topic_logs', 'topic', false, false, false);
$rountingKey = 'abc.def.ghi';
$msg = new AMQPMessage($data);
$channel->basic_publish($msg, 'topic_logs', $rountingKey);
Т.е. просто делаем publish в exchange без всяких очередей.
Я когда попробовал так же сделать через веб-интерфейс RabbitMQ, он мне сообщил, что Message published, but not routed.
Видимо из-за этого же и код примера не работает так как надо.
Или это я криворукий и что-то не так понял?
Правильно ли я понимаю, что биндить очередь надо всегда с exchange, даже когда речь идет про тип topic?
Может кто-то поделиться работающий примером как работать с topics и писателю и читателю?
Спасибо.
в вашей схеме не хватает хотя бы одной очереди, подписанной на эксчейндж
Обсуждают сегодня