Tutorial by Examples

Start with importing the library. from amqpstorm import Connection When consuming messages, we first need to define a function to handle the incoming messages. This can be any callable function, and has to take a message object, or a message tuple (depending on the to_tuple parameter defined in ...

Start with importing the library. from amqpstorm import Connection from amqpstorm import Message Next we need to open a connection to the RabbitMQ server. connection = Connection('127.0.0.1', 'guest', 'guest') After that we need to set up a channel. Each connection can have multiple channel...

First we need to set up two basic channels, one for the main queue, and one for the delay queue. In my example at the end, I include a couple of additional flags that are not required, but makes the code more reliable; such as confirm delivery, delivery_mode and durable. You can find more informatio...