amqpstorm_rabbitmq_publish_and_consume_quickstart.py

1import amqpstorm
2
3# Connection parameters
4connection_params = {
5    'hostname': 'localhost',
6    'username': 'guest',
7    'password': 'guest',
8    'port': 5672
9}
10
11# Create a connection and a channel
12with amqpstorm.Connection(**connection_params) as connection:
13    with connection.channel() as channel:
14        # Declare a queue
15        channel.queue.declare('test_queue')
16
17        # Publish a message
18        channel.basic.publish(body='Hello World!', routing_key='test_queue')
19
20        # Consume a message
21        def callback(message):
22            print("Received: " + message.body)
23            message.ack()
24
25        channel.basic.consume(callback=callback, queue='test_queue', no_ack=False)
26        channel.start_consuming(to_tuple=False)