ABCStreamMessage

faststream.broker.message.ABCStreamMessage `dataclass` #

Bases: Generic[Msg]

A generic class to represent a stream message.

body: Union[bytes, Any]

committed: bool = field(default=False, init=False)

content_type: Optional[str] = None

correlation_id: str = field(
    default_factory=lambda: str(uuid4())
)

decoded_body: Optional[DecodedMessage] = None

headers: AnyDict = field(default_factory=dict)

message_id: str = field(
    default_factory=lambda: str(uuid4())
)

path: AnyDict = field(default_factory=dict)

processed: bool = field(default=False, init=False)

raw_message: Msg

reply_to: str = ''