Skip to content

RedisMessage

faststream.redis.message.RedisMessage dataclass #

RedisMessage(raw_message: Msg, body: Union[bytes, Any], decoded_body: Optional[DecodedMessage] = None, headers: AnyDict = dict(), path: AnyDict = dict(), content_type: Optional[str] = None, reply_to: str = '', message_id: str = lambda: str(uuid4())(), correlation_id: str = lambda: str(uuid4())())

Bases: RedisAckMixin[AnyRedisDict]

A class to represent a Redis message.