pika_rabbitmq_basic_producer_hello_world_message.py

1import pika
2
3# Establish a connection with RabbitMQ server
4connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
5channel = connection.channel()
6
7# Create a queue to which the message will be delivered
8channel.queue_declare(queue='hello')
9
10# Send a message through an exchange (using the default empty string exchange)
11channel.basic_publish(exchange='',
12                      routing_key='hello',
13                      body='Hello World!')
14
15print(" [x] Sent 'Hello World!'")
16
17# Close the connection to ensure network buffers are flushed
18connection.close()