Subscriber¶
Example:
from message_queue import AMQPAdapter
from message_queue import Subscriber
def worker(channel, method, properties, body):
print body
adapter = AMQPAdapter(host='0.0.0.0')
subscriber = Subscriber(adapter)
subscriber.consume(worker)
Subscribe to a specific queue and consume the messages.
-
class
message_queue.subscriber.
Subscriber
(adapter)¶ -
__init__
(adapter)¶ Create a new subscriber with an Adapter instance.
Parameters: adapter (BaseAdapter) – Connection Adapter
-
consume
(worker)¶ Consume a queued message.
Parameters: worker (function) – Worker to execute when consuming the message
-