Publisher

Example:

from message_queue import AMQPAdapter
from message_queue import Publisher
from message_queue import Message

adapter = AMQPAdapter(host='0.0.0.0')
publisher = Publisher(adapter)

message = Message({ 'id': 1 })

publisher.publish(message)

Message Queue Publisher.

class message_queue.publisher.Publisher(adapter)
__init__(adapter)

Create a new publisher with an Adapter instance.

Parameters:adapter (BaseAdapter) – Connection Adapter
publish(message)

Publish a message message.

Parameters:message (Message) – Message to publish in the channel