We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
suggest to change interface of consuming messages from registering call_back on_message to iterating by some message generator: something like:
on_message
await mq.connect(conf) await mq.create_channel() await mq.declare_queue(queue_name) await self.mq.queue_bind(queue_name, '#') **async for msg in self.mq.basic_consume(self.on_message, queue_name):** **'do something with message'**
As example looks at websocket handler in aiohttp.
The text was updated successfully, but these errors were encountered:
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
Sorry, something went wrong.
cool!
No branches or pull requests
suggest to change interface of consuming messages from registering call_back
on_message
to iterating by some message generator:something like:
As example looks at websocket handler in aiohttp.
The text was updated successfully, but these errors were encountered: