Bases: Generic[Msg]
A generic class to represent a stream message.
Note
The above docstring is autogenerated by docstring-gen library (https://docstring-gen.airt.ai)
content_type class-attribute instance-attribute
content_type: Optional[str] = None
correlation_id class-attribute instance-attribute
correlation_id: str = field(
default_factory=lambda: str(uuid4())
)
decoded_body class-attribute instance-attribute
decoded_body: Optional[DecodedMessage] = None
headers: AnyDict = field(default_factory=dict)
message_id class-attribute instance-attribute
message_id: str = field(
default_factory=lambda: str(uuid4())
)
path class-attribute instance-attribute
path: AnyDict = field(default_factory=dict)
processed class-attribute instance-attribute
raw_message instance-attribute
reply_to class-attribute instance-attribute