rabbit-tutorial/new_task.py

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

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

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

channel.queue_declare(queue="task_queue", durable=True)
channel.basic_publish(
    exchange="",
    routing_key="task_queue",
    body=message,
    properties=pika.BasicProperties(delivery_mode=2),  # make message persistent
)
print(" [x] Sent {0}".format(message))

connection.close()