Message

Example:

from message_queue import Message

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

Create messages to publish in the queue.

class message_queue.message.Message(content, **kwargs)

__init__(content, **kwargs)

Create a new message.

Parameters:

• content (dict) – Content of the message
• kwargs (dict) – Extra parameters for the message

get_content()

Get the message content.

Return type:dict

to_json(content)

Convert content to json.

Parameters:content (dict) – Content to encode in json format Returns type:string