import pika

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

channel = connection.channel()
channel.queue_declare(queue='test_queue')

channel.basic_publish(
    exchange='',
    routing_key='test_queue',
    body='Hello RabbitMQ'
)

print("Message sent")

connection.close()