asyncapi-python
asyncapi-python copied to clipboard
AMQP support
Are there plans to support AMQP? And if there are not, could you point me to the right places in the code so that maybe I could try and implement it myself?
Ah, I see we're using the https://github.com/encode/broadcaster library, which doesn't yet support AMQP, though it doesn't seem too hard to implement the methods that are needed using something like https://github.com/mosquito/aiormq
I'm thinking that I need to implement the following methods in asyncacpi/events/backends/amqp.py
class AmqpBackend():
def __init__():
pass
async def connect():
pass
async def disconnect():
pass
async def publish():
pass
async def subscribe():
pass
and at least the subscribe method need to yield .event as I see it in api.py:listen.