Проблема с 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()

Ответы (0 шт):