Skip to content

BatchRedisMessage

faststream.redis.message.BatchRedisMessage dataclass #

BatchRedisMessage(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[BatchMessage]

A class to represent a Redis batch of messages.