mosquito / aio-pika

AMQP 0.9 client designed for asyncio and humans.
https://aio-pika.readthedocs.org/
Apache License 2.0
1.18k stars 186 forks source link

Publishing Message - NOT_IMPLEMENTED - immediate=true #617

Closed Friendliness closed 23 hours ago

Friendliness commented 4 months ago

Hey there,

When trying to use the immediate flag when publishing a message I seem to be getting an error: NOT_IMPLEMENTED - immediate=true Is the immediate flag indeed not implemented or am I perhaps doing something wrong?

aio-pika version: 9.4.0

This is a snippet of how I'm attempting to send the message:

message = Message(body=json_as_bytes, delivery_mode=DeliveryMode.
await self.channel.default_exchange.publish(message, routing_key=queue_name, timeout=20, immediate=True)
mosquito commented 4 months ago

It seems that the broker is not processing this flag as well. I recommend that you see the answer in your broker's documentation.

Friendliness commented 23 hours ago

Sorry for the late reply, seems the immediate flag was removed! Thanks for getting back to me :)