Skip to content

ZmqttFakeProducer

faststream.mqtt.publisher.producer.ZmqttFakeProducer #

ZmqttFakeProducer()

Bases: ZmqttBaseProducer

Source code in faststream/mqtt/publisher/producer.py 
223
def __init__(self) -> None: ...

codec instance-attribute #

codec: CodecProto = DefaultCodec()

serializer instance-attribute #

serializer: SerializerProto | None = None

id_generator instance-attribute #

id_generator = id_generator

connect #

connect(
    client: MQTTClient,
    serializer: Optional[SerializerProto],
    codec: Optional[CodecProto] = None,
) -> None
Source code in faststream/mqtt/publisher/producer.py 
227
228
229
230
231
232
233
def connect(
    self,
    client: "zmqtt.MQTTClient",
    serializer: Optional["SerializerProto"],
    codec: Optional["CodecProto"] = None,
) -> None:
    raise NotImplementedError

disconnect #

disconnect() -> None
Source code in faststream/mqtt/publisher/producer.py 
235
236
def disconnect(self) -> None:
    raise NotImplementedError

publish async #

publish(cmd: MQTTPublishCommand) -> None
Source code in faststream/mqtt/publisher/producer.py 
73
74
75
@override
async def publish(self, cmd: "MQTTPublishCommand") -> None:
    raise NotImplementedError

request async #

request(cmd: MQTTPublishCommand) -> Any
Source code in faststream/mqtt/publisher/producer.py 
77
78
79
@override
async def request(self, cmd: "MQTTPublishCommand") -> Any:
    raise NotImplementedError

publish_batch async #

publish_batch(cmd: MQTTPublishCommand) -> None
Source code in faststream/mqtt/publisher/producer.py 
81
82
83
84
@override
async def publish_batch(self, cmd: "MQTTPublishCommand") -> None:
    msg = "MQTT does not support batch publishing."
    raise FeatureNotSupportedException(msg)