Mosquito
Mosquito
All classes inherited from `aiormq.base.Base` has a `self.closing` future. So you have two options, wait for it in a background task, or use `.closing.add_done_callback(callback)`. It's might be applicable for channels...
4.x.x branch is unstable now. Sorry for no mensions.
I guess that you are doing something wrong. The fact is that the confirmation object is asyncio.Future, and when confirmation frame comes from the broker, it turns out that the...
@mikeoconnor0308 just use transactions
@bluesliverx ouch, I should be write this comment earlier, but doesn't sorry. I completely do not understand why I will want to apply this example in real project when to...
@cloud-rocket please rebase it against master branch
Sorry, miss clicked
I will review it on weekends. Busy right now.
@cloud-rocket sorry for delay, a new version 9.3.0 has been released with your changes
@nosahama when you have to process messages asyncronously please use `.consume` method, this is blazingly fast.