Skip to content

OneMessage

faststream.redis.message.OneMessage #

Bases: PubSubMessage

A class to represent a PubSub message.

channel instance-attribute #

channel: bytes

data instance-attribute #

data: bytes

message_id instance-attribute #

message_id: NotRequired[str]

message_ids instance-attribute #

message_ids: NotRequired[List[str]]

pattern instance-attribute #

pattern: NotRequired[Optional[bytes]]

type instance-attribute #

type: Literal['stream', 'list', 'message']