Coverage for docs / docs_src / getting_started / opentelemetry / mqtt_telemetry.py: 0%

1from faststream import FastStream 

2from faststream.mqtt import MQTTBroker 

3from faststream.mqtt.opentelemetry import MQTTTelemetryMiddleware 

4 

5broker = MQTTBroker( 

6 middlewares=( 

7 MQTTTelemetryMiddleware(tracer_provider=tracer_provider), 

8 ), 

9) 

10app = FastStream(broker)