amqpy
amqpy copied to clipboard
veegee
Pure-Python 2 & 3 AMQP client library
When trying to detect connection failures on a connection, an application can look at the last_heartbeat_recv datetime(which comes from the underlying transport object) to determine if rabbitmq is still in...
This patch adds support for AMQP connection string passed as the `host` parameter when creating a `Connection`. This is linked to issue #33 but does not contain cluster support.
Add more examples in examples directory and update Sphinx docs with better examples.
In the [online docs][amqpy-docs], API documentation exists for almost all of the fundamental stuff *except* the `AbstractConsumer` class, which is subclassed in the usage examples. After looking in the code,...
Hi, I recently stumbled upon this library and replaced my kombu setup with it. So far it works great and is faster than kombu. Now the only problem I'm having...
When I try drain_events in first thread and publish message in obtained channel in second thread I never get the channel in second thread. Possible dead lock or i will...
Producer continues to `publish` and Consumer's `loop` is stuck silently on failure of network connection to broker. How should a client application be notified that the connection is broken? A...
See #29 Connection and channel operations currently lock the connection and wait until the operation is complete. This provides thread safety, but slightly reduces performance in highly concurrent code when...
…_received If server fails to send us its heartbeat, we should assume it's dead/gone. NB: The heartbeat thread doesn't execute drain_events() calls, so the user - if he activated the...
It would be nice to get this easily working with Kombu.