RabbitMQ — непрерывная связь между производителем и потребителем

У меня вопрос - Как сохранить непрерывную связь между потребителем и производителем?

Я имею в виду, когда производитель отправляет сообщения - потребитель обрабатывает их и отправляет обратно с очередью обратного вызова, если я использовал процедуру rpc, и соединение будет закрыто.

Теперь я хочу, чтобы связь между потребителем и производителем была открыта. Как этого добиться?

Спасибо


rabbitmq php message-queue php-amqp
person Raj Sf    schedule 10.04.2014    source источник
comment
Немного непонятно, что вы спрашиваете. И потребитель (и), и производитель (и) подключаются к брокеру, а не друг к другу. Если вы не хотите закрывать соединение и иметь активных потребителей, ожидающих нового сообщения, просто оставьте их в живых.   -  person pinepain    schedule 10.04.2014
comment
Да, мой потребитель активен. На самом деле я знаю, что и потребитель, и производитель подключаются к RabbitMQ асинхронно. но я хочу, чтобы соединение между потреблением и производителем было открытым, чтобы, если я хочу отправлять сообщения производителю, я мог отправлять сообщения через это открытое соединение, которое я хочу.   -  person Raj Sf    schedule 10.04.2014

Ответы (1)


arrow_upward
0
arrow_downward

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

person Lucifer    schedule 15.03.2016