aio-libs / aioamqp_consumer Goto Github PK

Hello guys.

I have tried use aioamqp_consumer with python 3.7 and there's a error that could be fixed simply updating aioamqp to version 0.11.0.

Python 3.7.6 (default, Jan 17 2020, 01:24:44) 
[GCC 9.2.1 20200104] on linux
Type "help", "copyright", "credits" or "license" for more information.
>>> import aioamqp
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File "/home/amenezes/Documents/github/aioamqp_consumer/venv/lib/python3.7/site-packages/aioamqp/__init__.py", line 8, in <module>
    from .protocol import AmqpProtocol
  File "/home/amenezes/Documents/github/aioamqp_consumer/venv/lib/python3.7/site-packages/aioamqp/protocol.py", line 13, in <module>
    from .compat import ensure_future
  File "/home/amenezes/Documents/github/aioamqp_consumer/venv/lib/python3.7/site-packages/aioamqp/compat.py", line 11
    ensure_future = asyncio.async
                                ^
SyntaxError: invalid syntax

Also to verify and validate backwards compatibility I appended python 3.7 and pypy 3.6 in the tox.ini file as:

[tox]
envlist =
    py3{5,6,7},pypy3.6
...

All tests work's properly. But another issue maybe related to my environment is that tox didn't work at first only after an update (pip install -U tox).

py35: commands succeeded
py36: commands succeeded
py37: commands succeeded
pypy3.6: commands succeeded
congratulations :)

However, I noticed that project dosen't have updates more than a year ago. So this project still alive? A PR for this use case is relevant or there are any roadmap to include this support?

There is no way to use Producer with exchanges and routing keys.

Hello,

I checked the documentation and code, but could not find how to set message properties, in my case the delivery_mode, using the RpcClient.

Would it be possible to add an option to configure the properties or point out how to do it if i missed it?

Thanks!

Merging #12 brings that any queue is binded to default routing key '', it means each message come all possible queues.

Here is my hotfix 0b23d53 , but I am not sure is right or not

@alternativshik can You take a look on it?

https://github.com/wikibusiness/aioamqp_consumer/blob/1ce1a7b2ecffb0bcc32f53ff2599fd057ce4f279/aioamqp_consumer/consumer.py#L305