Cluster.start(wait=True) should wait for attaches

smok-serwis / coolamqp

Pure Python pretty fast AMQP client with sane reconnects

MIT License

6 stars 1 forks source link

Closed piotrmaslanka closed 4 years ago

piotrmaslanka commented 7 years ago

Because now it doesn't, and you can drop non-tx messages.

piotrmaslanka commented 4 years ago

It sorta does now. Especially, Publisher being up tells the Cluster whether it's been connected or not