Skip to content

RabbitSubscriberConfig

faststream.rabbit.subscriber.config.RabbitSubscriberConfig dataclass #

RabbitSubscriberConfig(
    *,
    _outer_config=RabbitBrokerConfig(),
    no_reply=False,
    _ack_policy=(lambda: EMPTY)(),
    queue,
    exchange,
    consume_args=None,
    channel=None,
    _no_ack=(lambda: EMPTY)(),
)

Bases: RabbitConfig, SubscriberUsecaseConfig

consume_args class-attribute instance-attribute #

consume_args = None

channel class-attribute instance-attribute #

channel = None

ack_first property #

ack_first

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)

queue instance-attribute #

queue

exchange instance-attribute #

exchange