Nate Coraor 6fef4465ae [Pulsar] Resubmit AMQP acknowledgement messages to the correct queue ...

when consuming more than one. Also, only start one acknowledgement
manager thread rather than one per consumer.

2015-09-28 15:07:07 -04:00

..

client

[Pulsar] Resubmit AMQP acknowledgement messages to the correct queue

2015-09-28 15:07:07 -04:00

__init__.py

Implement Pulsar job runners.

2014-06-20 00:28:36 -05:00