refactor: remove OTEL explicit integration

Author: Lancetnik

README.md

@@ -150,16 +150,17 @@ taskiq_broker.task(
 
 ## OpenTelemetry Support
 
-**taskiq-faststream** supports distributed tracing with OpenTelemetry. To enable it, install the `otel` extra and pass `enable_otel=True` when creating the broker wrapper:
+**taskiq-faststream** supports taskiq's OpenTelemetry middleware. To enable it, pass `OpenTelemetryMiddleware` when creating the broker wrapper:
 
 ```python
 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, enable_otel=True)
+taskiq_broker = BrokerWrapper(broker, middlewares=[OpenTelemetryMiddleware()])
 ```
 
 This will automatically add OpenTelemetry middleware to track task execution, providing insights into:
@@ -175,9 +176,10 @@ The same applies to `AppWrapper`:
 ```python
 from faststream import FastStream
 from taskiq_faststream import AppWrapper
+from taskiq.middlewares.otel_middleware import OpenTelemetryMiddleware
 
 app = FastStream(broker)
 
 # Enable OpenTelemetry middleware
-taskiq_broker = AppWrapper(app, enable_otel=True)
+taskiq_broker = AppWrapper(app, middlewares=[OpenTelemetryMiddleware()])
 ```

taskiq_faststream/broker.py

@@ -1,23 +1,20 @@
 import typing
 import warnings
+from collections.abc import Iterable
 from typing import Any, TypeAlias
 
 import anyio
 from faststream._internal.application import Application
 from faststream.types import SendableMessage
 from taskiq import AsyncBroker
+from taskiq.abc.middleware import TaskiqMiddleware
 from taskiq.acks import AckableMessage
 from taskiq.decor import AsyncTaskiqDecoratedTask
 
 from taskiq_faststream.formatter import PatchedFormatter, PatchedMessage
 from taskiq_faststream.types import ScheduledTask
 from taskiq_faststream.utils import resolve_msg
 
-try:
-    from taskiq.middlewares.otel_middleware import OpenTelemetryMiddleware
-except ImportError:
-    OpenTelemetryMiddleware = None  # type: ignore[assignment,misc]
-
 PublishParameters: TypeAlias = typing.Any
 
 
@@ -39,27 +36,18 @@ def __init__(
         self,
         broker: Any,
         *,
-        enable_otel: bool = False,
+        middlewares: Iterable[TaskiqMiddleware] = (),
     ) -> None:
         """Initialize BrokerWrapper.
 
         Args:
             broker: FastStream broker instance to wrap.
-            enable_otel: Enable OpenTelemetry middleware for distributed tracing.
-                Requires taskiq[otel] to be installed.
+            middlewares: Middlewares to add to the broker.
         """
         super().__init__()
         self.formatter = PatchedFormatter()
         self.broker = broker
-
-        if enable_otel:
-            if OpenTelemetryMiddleware is None:
-                msg = (
-                    "OpenTelemetry middleware requires taskiq[otel] to be installed. "
-                    "Install it with: pip install taskiq-faststream[otel]"
-                )
-                raise ImportError(msg)
-            self.middlewares.append(OpenTelemetryMiddleware())
+        self.add_middlewares(*middlewares)
 
     async def startup(self) -> None:
         """Startup wrapped FastStream broker."""
@@ -135,27 +123,18 @@ def __init__(
         self,
         app: Application,
         *,
-        enable_otel: bool = False,
+        middlewares: Iterable[TaskiqMiddleware] = (),
     ) -> None:
         """Initialize AppWrapper.
 
         Args:
             app: FastStream application instance to wrap.
-            enable_otel: Enable OpenTelemetry middleware for distributed tracing.
-                Requires taskiq[otel] to be installed.
+            middlewares: Middlewares to add to the broker.
         """
         super(BrokerWrapper, self).__init__()
         self.formatter = PatchedFormatter()
         self.app = app
-
-        if enable_otel:
-            if OpenTelemetryMiddleware is None:
-                msg = (
-                    "OpenTelemetry middleware requires taskiq[otel] to be installed. "
-                    "Install it with: pip install taskiq-faststream[otel]"
-                )
-                raise ImportError(msg)
-            self.middlewares.append(OpenTelemetryMiddleware())
+        self.add_middlewares(*middlewares)
 
     async def startup(self) -> None:
         """Startup wrapped FastStream."""