Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
# coding=utf-8
import pika
import environ
env = environ.Env()
environ.Env.read_env()
rabbitmq_url = env("RABBITMQ_URL")
params = pika.URLParameters(rabbitmq_url)
connection = pika.BlockingConnection(params)
channel = connection.channel()
channel.queue_declare(queue='intro_rabbitmq')
channel.basic_publish(exchange='', routing_key='intro_rabbitmq', body='Ola Mundo!')
print(" [x] Enviado 'Ola Mundo!'")
connection.close()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment