Skip to content

NatsSubscriberConfig

faststream.nats.subscriber.config.NatsSubscriberConfig dataclass #

NatsSubscriberConfig(
    *,
    _outer_config: NatsBrokerConfig = NatsBrokerConfig(),
    no_reply: bool = False,
    _ack_policy: AckPolicy = (lambda: EMPTY)(),
    subject: str,
    sub_config: ConsumerConfig,
    extra_options: dict[str, Any] | None = dict(),
    _ack_first: bool = (lambda: EMPTY)(),
    _no_ack: bool = (lambda: EMPTY)(),
)

Bases: SubscriberUsecaseConfig

subject instance-attribute #

subject: str

sub_config instance-attribute #

sub_config: ConsumerConfig

extra_options class-attribute instance-attribute #

extra_options: dict[str, Any] | None = field(
    default_factory=dict
)

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