aio-pika
aio-pika copied to clipboard
mosquito
AMQP 0.9 client designed for asyncio and humans.
The `no_ack` parameter seems like it's named incorrectly and to me signals that when set to True, that means acknowledgements will _NOT_ be done automatically. However the documentation (and actual...
aiormq master branch now has support for a pre-baked SSLContext where I could set all options, but it is not accessible from aio-pika. I couldn't find how to specify a...
Hello everybody. I have a big app wich declare all neede queues and exchanges, and I have the microservice witch should use it. I don't want to keep consistent configuration...
Hello, I was wondering if there is any message size limitation using aio-pika? because i was using pika before, and due to various motivations, i switched to aio-pika, but some...
See: https://github.com/mosquito/aio-pika/blob/5af608d05b05d65632652f0632d00af4729b265b/aio_pika/connection.py#L315-L330 If a URL is passed into `connect` or `connect_robust`, all keyword arguments (including `ssl_options` and things like `reconnect_interval`) are completely ignored. I can work around this by just...
I'm connecting to an HA RabbitMQ cluster. My understanding is that a RabbitMQ cluster has a single master node with the remaining as slaves. Communication to a slave gets forwarded...
Now If I write ``` async with message.process(requeue=True), channel.transaction(): message.ack() raise Exception ``` I got MessageProcessError because ack method set `__processed` in true. Also, I can't call reject manually after...
Declaring a queue with the following arguments: {'x-max-priority': 255} raises: ``` ../../lala/utils/rabbitmq.py:160: in _declare_tasks_queue arguments=self.queue_arguments) ../../../../anaconda3/envs/lala/lib/python3.7/site-packages/aio_pika/robust_channel.py:173: in declare_queue timeout=timeout, ../../../../anaconda3/envs/lala/lib/python3.7/site-packages/aio_pika/channel.py:303: in declare_queue await queue.declare(timeout=timeout) ../../../../anaconda3/envs/lala/lib/python3.7/site-packages/aio_pika/queue.py:101: in declare timeout=timeout, ../../../../anaconda3/envs/lala/lib/python3.7/asyncio/tasks.py:388: in...
Setting a timeout for an operation might break the connection and make it unusable. ``` ../../Library/Caches/pypoetry/virtualenvs/-om8xx-H_-py3.8/lib/python3.8/site-packages/aio_pika/robust_channel.py:173: in declare_queue queue = await super().declare_queue( ../../Library/Caches/pypoetry/virtualenvs/-om8xx-H_-py3.8/lib/python3.8/site-packages/aio_pika/channel.py:310: in declare_queue await queue.declare(timeout=timeout) ../../Library/Caches/pypoetry/virtualenvs/-om8xx-H_-py3.8/lib/python3.8/site-packages/aio_pika/queue.py:92: in declare...
Should the RPC pattern use the direct reply-to queue `amq.rabbitmq.reply-to` as described here: https://www.rabbitmq.com/direct-reply-to.html? I'm also surprised to see a reply-to queue being created by the RPC server as well,...
