Проблема с rabbitmq
Я тут попробовал поиграться с rabbitmq. Но я столкнулся с проблемой, когда пробую подключиться к нему(rabbitmq), у меня вылазит ошибка: pika.exceptions.IncompatibleProtocolError: StreamLostError: ('Transport indicated EOF',)
Может кто-то уже сталкивался с этим и может помочь. Может я плохо гуглил, и не смог найти ответ.
Код сендера:
import pika
conn_params = pika.ConnectionParameters(host='localhost')
connection = pika.BlockingConnection(conn_params)
channel = connection.channel()
channel.queue_declare(queue='hello-queue')
channel.basic_publish(
exchange='',
routing_key='hello-queue',
body='Hello from python and rabbitmq (IllyaMoss)'
)
connection.close()
Код обработчика:
import pika
conn_params = pika.ConnectionParameters(host='localhost')
connection = pika.BlockingConnection(conn_params)
channel = connection.channel()
channel.queue_declare(queue='hello-queue')
def callback(channel, method, properties, body):
print(body)
channel.basic_consume(callback,queue='hello-queue', no_ack=True)
channel.start_consuming()