#!/usr/bin/env python
import logging
import pika
import ssl
from pika.credentials import ExternalCredentials
logging.basicConfig(level=logging.INFO)
context = ssl.create_default_context(cafile="RabbitMQCluster.crt")
context.load_cert_chain("RabbitMQ.crt",
"rabbitkey.pem")
x = pika.PlainCredentials("user","pass")
ssl_options = pika.SSLOptions(context, 'RabbitMQ_Server')
conn_params = pika.ConnectionParameters(host='IP',
port=5671,
ssl_options=ssl_options,
credentials=x,
heartbeat=0)
with pika.BlockingConnection(conn_params) as conn:
ch = conn.channel()
ch.queue_declare("foobar")
ch.basic_publish("", "foobar", "Hello, world!")
print(ch.basic_get("foobar"))
input("Press Enter to continue...")
Can someone help me or explain me why this is not working?