NatsSubscriberConfig

faststream.nats.subscriber.config.NatsSubscriberConfig dataclass

NatsSubscriberConfig(
    *,
    _outer_config=NatsBrokerConfig(),
    no_reply=False,
    _ack_policy=(lambda: EMPTY)(),
    subject,
    sub_config,
    extra_options=dict(),
    _ack_first=(lambda: EMPTY)(),
    _no_ack=(lambda: EMPTY)(),
)

Bases: SubscriberUsecaseConfig

subject instance-attribute

subject

sub_config instance-attribute

sub_config

extra_options class-attribute instance-attribute

extra_options = field(default_factory=dict)

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)