Skip to content

Latest commit

 

History

History
24 lines (16 loc) · 429 Bytes

publisher.rst

File metadata and controls

24 lines (16 loc) · 429 Bytes

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