Mosquito
Mosquito
@cloud-rocket please rebase against the master branch
`ConnectionError('Auto Reconnect Error')` will be set to all undone futures. In the case when `connect_robust` using, the connection state will be repared.
The `Connect.add_close_callback` adds callback which will be called when connection lost. The `RobustConnection()` class accept the `reconnect_interval=` keyword argument, this might be passed like this: `connect_robust(..., reconnect_interval=0.1)`
I can't give an answer for this example. The example should be at least a runable script. If we take the code from the examples, then there are no such...
Very strange fix. When your right that's not working right now, but tests says isn't this.
It’s wrong
@cloud-rocket why have the fallen tests have been ignored?
@screech since bump `aio-pika>7.0.0`, the `JsonRPC`-related classes was refactored and now you may change theirs behaviour with inheritance.
Just add `mandatory=False` on publish
@pfribourg-ias What decision do you expect from me? I can teach you how to disable logs. This message in the log says that for some reason the broker sent a...