"""
FastStream middleware for observability and error handling.

This module provides middleware for adding metrics, tracing, and
enhanced error handling to FastStream message processing.
"""

import logging
from typing import Any, Awaitable, Callable

logger = logging.getLogger(__name__)


def setup_middleware(broker):
    """
    Set up all middleware for the FastStream broker.

    Args:
        broker: FastStream Redis broker instance

    Note: Middleware setup is simplified for compatibility.
    Can be enhanced with custom middleware implementations as needed.
    """
    logger.info("FastStream broker configured (middleware setup placeholder)")