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
-