send_message_test.py

#!/usr/bin/env python
import pika
import sys

#Example publisher code take from RabbitMQ  topic tutorial

routing_key = sys.argv[1] if len(sys.argv) > 1 else 'anonymous.info'
message = ' '.join(sys.argv[2:]) or 'Hello World!'
channel.basic_publish(exchange='data_gateway',
                      routing_key=routing_key,
                      body=message,
                      properties=pika.BasicProperties(delivery_mode =2,))
print " [x] Sent %r:%r" % (routing_key, message)
connection.close()