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