Я хочу отправить мессадж в RabbitMQ. Я обьявляю connection:
db.client = await connect("amqp://user:mysweetrabbit@ff_rabbitmq")
После чего использую channel. При этом очередь, в которую я отправляю мессадж, заранее декларируется с помощью такой функции:
async def get_rabbitmq_channel(queues_to_declare=None) -> Channel:
if queues_to_declare is None:
queues_to_declare = []
chan = await db.client.channel()
for q in queues_to_declare:
chan.declare_queue(q)
return chan
Потом для отправки я делаю вот так:
await rabbit_channel.default_exchange.publish(
Message(
body=str(
NewFaceToRabbit(image_id=str(image_id), task_id=task_id, trait_id=str(trait_id.inserted_id),
append=append_face).dict()).encode()
),
routing_key="addface" # эта очередь была определена с помощью delcare_queue в функции выше
)
И.. Ничего. Никаких Exceptionов не возникает, но я не вижу сообщения в очереди addface (Я использую Jms Messenger, плагин для IDE JetBrains). Что я делаю не так?
