Mosquito

You should call consume for the queue. [This example](http://aio-pika.readthedocs.io/en/latest/quick-start.html#simple-consumer) do it easer.

[This example](https://aio-pika.readthedocs.io/en/latest/quick-start.html#asynchronous-message-processing) demonstrated the asynchronous message processing

The `basic.get` method marked as synchronous on the [documentation (page 54)](https://www.rabbitmq.com/resources/specs/amqp-xml-doc0-9-1.pdf) ``` Synchronous: Yes; expected response is from method(s) basic.get­ok, basic.get­empty ``` You should use this method on very specific...

@nurettin just `set_qos(prefetch_count=1)` and stop consuming before ack

@YuryHrytsuk it should, we have a lot of tests for this behaviour for example [this one](https://github.com/mosquito/aio-pika/blob/master/tests/test_amqp_robust_proxy.py#L459-L483). Bugs happen, of course, if you have a reproducible example, describe it, it’s worth...

feel free to open PR with adding `ready()` to abstract class

I don't know the specifics of pyinstaller's behavior, but that commit doesn't have anything directly related to packaging. My hypothesis is that [these lines](https://github.com/mosquito/aio-pika/commit/001dcce791b1bb441025757562202f9115e8ee80#diff-64b7cf25f8a1c81c96f634498359cfe50235e8826c98fe739dabdae5aca5ac4aL16) cause an exception at import time...

Excellent that's means I probably right. Ok, I will thinking about the another way to bring the version in a package

Use `message.process(ignore_processed=True)` like this: ```python import aio_pika async def _process_message(message: aio_pika.abc.AbstractIncomingMessage): async with message.process(ignore_processed=True): try: body = message.body.decode("utf-8") # DO SOMETHING # After this context-manager do nothing with a message...

https://github.com/mosquito/caio/blob/fae3c9e7875aefdf8ef8a6a45eced860f5b69034/caio/linux_aio.c#L21 Libaio in not needed