Skip to content

RedisSubscriberConfig

faststream.redis.subscriber.config.RedisSubscriberConfig dataclass #

RedisSubscriberConfig(
    *,
    _outer_config: RedisBrokerConfig,
    no_reply: bool = False,
    _ack_policy: AckPolicy = (lambda: EMPTY)(),
    list_sub: ListSub | None = None,
    channel_sub: PubSub | None = None,
    stream_sub: StreamSub | None = None,
    _no_ack: bool = (lambda: EMPTY)(),
    _message_format: type[MessageFormat] | None = None,
)

Bases: SubscriberUsecaseConfig

list_sub class-attribute instance-attribute #

list_sub: ListSub | None = field(default=None, repr=False)

channel_sub class-attribute instance-attribute #

channel_sub: PubSub | None = field(default=None, repr=False)

stream_sub class-attribute instance-attribute #

stream_sub: StreamSub | None = field(
    default=None, repr=False
)

message_format property #

message_format: type[MessageFormat]

ack_policy property #

ack_policy: AckPolicy

no_reply class-attribute instance-attribute #

no_reply: bool = False

parser class-attribute instance-attribute #

parser: AsyncCallable = field(init=False)

decoder class-attribute instance-attribute #

decoder: AsyncCallable = field(init=False)

auto_ack_disabled property #

auto_ack_disabled: bool