Skip to content

RabbitSubscriberConfig

faststream.rabbit.subscriber.config.RabbitSubscriberConfig dataclass #

RabbitSubscriberConfig(
    *,
    _outer_config: RabbitBrokerConfig = RabbitBrokerConfig(),
    no_reply: bool = False,
    _ack_policy: AckPolicy = (lambda: EMPTY)(),
    queue: RabbitQueue,
    exchange: RabbitExchange,
    consume_args: dict[str, Any] | None = None,
    channel: Optional[Channel] = None,
    _no_ack: bool = (lambda: EMPTY)(),
)

Bases: RabbitConfig, SubscriberUsecaseConfig

consume_args class-attribute instance-attribute #

consume_args: dict[str, Any] | None = None

channel class-attribute instance-attribute #

channel: Optional[Channel] = None

ack_first property #

ack_first: bool

auto_ack_disabled property #

auto_ack_disabled: bool

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)

queue instance-attribute #

queue: RabbitQueue

exchange instance-attribute #

exchange: RabbitExchange