Search code examples
pythonrabbitmqmessagingpika

RPC calls to multiple consumers


I have a consumer which listens for messages, if the flow of messages is more than the consumer can handle I want to start another instance of this consumer.

But I also want to be able to poll for information from the consumer(s), my thought was that I could use RPC to request this information from the producers by using a fanout exchange so all the producers gets the RPC-call.

My question is first of all is this possible and secondly is it reasonable?


Solution

  • After some researching it seems that this is not possible. If you look at the tutorial on RabbitMQ.com you see that there is an id for the call which, as far as I understand gets consumed.

    I've choosen to go another way, which is reading the log-files and aggregating the data.