Skip to content

0.4.0

Latest

Choose a tag to compare

@Lancetnik Lancetnik released this 25 Dec 19:18
63dafcb

What's Changed

Taskiq's native middlewares support #121

from faststream.nats import NatsBroker
from taskiq_faststream import BrokerWrapper
from taskiq.middlewares.otel_middleware import OpenTelemetryMiddleware

broker = NatsBroker()

# Enable OpenTelemetry middleware
taskiq_broker = BrokerWrapper(broker, middlewares=[OpenTelemetryMiddleware()])

Full Changelog: 0.3.2...0.4.0