Mosquito

Results 223 comments of Mosquito

Tell me more about your task, it looks like you are trying to misuse rabbitmq correctly in the above problem statement.

This library is a low level library. aio-pika is a high level wrapper for this library and provides this interface https://aio-pika.readthedocs.io/en/latest/quick-start.html

You might pass `ssl_context` argument to to the `__init__`'s `**kwargs`. This will be passed to the `aiohttp.Session`.

Could you do it. I guess. :-)

I already did this once for aiohttp-jsonrpc [here](https://github.com/mosquito/aiohttp-jsonrpc/blob/master/aiohttp_jsonrpc/client.py#L136-L181), I think this simple approach could be useful to you.

Unfortunately, all it's impossible. If `no_ack` flag has been set all messages automatically acks after receiving. But in manual ack mode, RabbitMQ returns, all messages to the queue and passing...

Sorry I can not imagine your case completely. I may provide some suggestions and recommendations. 1. Do not prefetch too much. Set QoS for the channel. 2. The network will...