import pika
from sys import argv
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.queue_declare(queue='hello')


channel.basic_publish(exchange='',
                      routing_key='hello',
                      body=argv[1])

print(" [x] Sent '{}'".format(argv[1]))

connection.close()