pika_rabbitmq_hello_world_message_producer.py

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