amqpstorm_basic_publish_consume_message_quickstart.py

1import amqpstorm
2
3# Create a connection
4connection = amqpstorm.Connection('localhost', 'guest', 'guest')
5
6# Create a channel
7channel = connection.channel()
8
9# Declare a queue
10channel.queue.declare('hello')
11
12# Publish a message
13channel.basic.publish(body='Hello World!', routing_key='hello')
14
15# Consume a message
16def callback(message):
17    print("Received: %r" % message.body)
18    message.ack()
19
20channel.basic.consume(callback=callback, queue='hello', no_ack=False)
21
22# Start consuming
23channel.start_consuming()
24
25# Close the connection
26connection.close()