sample publisher using rabbitmq pika client

publisher.py

import pika
import sys

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.exchange_declare(exchange='direct_exchange', exchange_type='direct')
channel.queue_declare(queue='direct_queue', durable=True)
channel.queue_bind(exchange='direct_exchange', queue="direct_queue", routing_key="direct.routing.key")

message = " ".join(sys.argv[1:]) or "Hello World!"

channel.confirm_delivery()
try:
    channel.basic_publish(exchange='direct_exchange', routing_key='direct.routing.key',
                          body=message, properties=pika.BasicProperties(delivery_mode=2)
                          )

    print("Sent %r" % message)
except pika.exceptions.UnroutableError:
    print("Failed to send message %r" % message)
connection.close()