dragon.ai.agent.communication.message.Message

class Message[source]

Bases: object

A message sent between dispatchers and agents.

Routing fields (consumed by the transport layer):

recipient_serialized_queue — serialized Dragon queue handle for the target agent. Used by DragonQueueProtocol.send() to deserialize the destination queue. Not read by the agent itself.

Content fields (received and processed by the agent):

header — a DispatchHeader containing the task description, upstream references, serialized DDict handle, and completion event. This is the only field the agent inspects inside its listen() loop.

__init__(task_id: str , sender_id: str , recipient_id: str , header: DispatchHeader | None = None, recipient_serialized_queue: str = '', id: str = <factory>) → None

Methods

__init__(task_id, sender_id, recipient_id, ...)

Attributes

header

recipient_serialized_queue

task_id

sender_id

recipient_id

id

task_id: str
sender_id: str
recipient_id: str
header: DispatchHeader | None = None
recipient_serialized_queue: str = ''
id: str
__init__(task_id: str , sender_id: str , recipient_id: str , header: DispatchHeader | None = None, recipient_serialized_queue: str = '', id: str = <factory>) → None