I have gone through the fundamentals of RabbitMQ. One thing I figured out that a publisher does not directly publish on a queue. The exchange decides on which queue the message should be published based on routing-key and type of exchange (code below is using default exchange). I have also found an example co…
Tag: pika
Running RabbitMQ Pika with Quart
I am using the Quart framework, but I also need to use the RabbitMQ Pika connector, but I can’t get them to play nice as they both have infinite loops. Entrypoint: Service Class: The code isn’t even getting to the print(‘Thread created…’) and I don’t understand. From this q…
Python and RabbitMQ – Best way to listen to consume events from multiple channels?
I have two, separate RabbitMQ instances. I’m trying to find the best way to listen to events from both. For example, I can consume events on one with the following: I have a second host, “host2”, that I’d like to listen to as well. I thought about creating two separate threads to do th…
How to create a delayed queue in RabbitMQ?
What is the easiest way to create a delay (or parking) queue with Python, Pika and RabbitMQ? I have seen an similar questions, but none for Python. I find this an useful idea when designing applications, as it allows us to throttle messages that needs to be re-queued again. There are always the possibility th…