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