rabbitmq_pika_producer_hello_world_message_queue.py

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