Я разработал Symfony2 веб-приложение с RabbitMqBundle, и оно работает нормально.
Теперь я пытаюсь настроить больше экземпляров того же приложения для других разработчиков. Итак, теперь у меня 9 экземпляров (dev01 - dev09). Я создал базы данных и настроил файлы для каждого экземпляра разработчика, и они работают нормально, кроме RabbitMq. Например, очередь сообщений, созданная dev01, но обработанная пользователем dev02 (должна обрабатываться dev01) и т. Д.
Я думаю, что мне нужно настроить соединения / производителей / потребителей для наших нескольких приложений, но я не знаю, с чего начать.
[Обновлено 23 января в 4:00 EST]
Для попытки я изменил имя в queue_options на «api.import.dev01». Однако он получил следующую ошибку, хотя я указываю обратный вызов "wl.api.import.consumer":
[Symfony\Component\DependencyInjection\Exception\ServiceNotFoundException] You have requested a non-existent service "old_sound_rabbit_mq.api.import.dev01_consumer".
Может ли кто-нибудь дать мне несколько указаний (например, ссылки на примеры или документацию)?
old_sound_rabbit_mq:
connections:
default:
host:"%mq.default.host%"
port:"%mq.default.port%"
user:"%mq.default.user%"
password:"%mq.default.pass%"
vhost:"%mq.default.vhost%"
lazy:"%mq.default.lazy%"
producers:
event:
connection: default
exchange_options: { name: 'event', type: topic }
auto_setup_fabric: false
consumers:
api.import:
connection: default
exchange_options:
name: 'event'
type: topic
queue_options:
name: 'api.import'
routing_keys:
- 'api.import.#'
callback: wl.api.import.consumer
qos_options: { prefetch_size: 0, prefetch_count: 100, global: false }
auto_setup_fabric: false