RedisSubscriberConfig

faststream.redis.subscriber.config.RedisSubscriberConfig dataclass

RedisSubscriberConfig(
    *,
    _outer_config,
    no_reply=False,
    _ack_policy=(lambda: EMPTY)(),
    list_sub=None,
    channel_sub=None,
    stream_sub=None,
    _no_ack=(lambda: EMPTY)(),
    _message_format=None,
)

Bases: SubscriberUsecaseConfig

list_sub class-attribute instance-attribute

list_sub = field(default=None, repr=False)

channel_sub class-attribute instance-attribute

channel_sub = field(default=None, repr=False)

stream_sub class-attribute instance-attribute

stream_sub = field(default=None, repr=False)

message_format property

message_format

ack_policy property

ack_policy

no_reply class-attribute instance-attribute

no_reply = False

parser class-attribute instance-attribute

parser = field(init=False)

decoder class-attribute instance-attribute

decoder = field(init=False)