Skip to content

MQTTSubscriberConfig

faststream.mqtt.subscriber.config.MQTTSubscriberConfig `dataclass` #

MQTTSubscriberConfig(
    *,
    _outer_config: MQTTBrokerConfig = MQTTBrokerConfig(),
    no_reply: bool = False,
    _ack_policy: AckPolicy = (lambda: EMPTY)(),
    topic: str,
    qos: QoS = AT_MOST_ONCE,
    shared: str | None = None,
)

Bases: SubscriberUsecaseConfig

topic `instance-attribute` #

topic: str

qos `class-attribute` `instance-attribute` #

qos: QoS = AT_MOST_ONCE

shared `class-attribute` `instance-attribute` #

shared: str | None = None

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