RedisRouterConfig

faststream.redis.configs.broker.RedisRouterConfig dataclass

RedisRouterConfig(
    *,
    prefix="",
    include_in_schema=True,
    broker_middlewares=(),
    broker_parser=None,
    broker_decoder=None,
    producer=ProducerUnset(),
    logger=LoggerState(),
    fd_config=FastDependsConfig(),
    broker_dependencies=(),
    graceful_timeout=None,
    extra_context=dict(),
)

Bases: BrokerConfig

connection property

connection

prefix class-attribute instance-attribute

prefix = ''

include_in_schema class-attribute instance-attribute

include_in_schema = True

broker_middlewares class-attribute instance-attribute

broker_middlewares = ()

broker_parser class-attribute instance-attribute

broker_parser = None

broker_decoder class-attribute instance-attribute

broker_decoder = None

producer class-attribute instance-attribute

producer = field(default_factory=ProducerUnset)

logger class-attribute instance-attribute

logger = field(default_factory=LoggerState)

fd_config class-attribute instance-attribute

fd_config = field(default_factory=FastDependsConfig)

broker_dependencies class-attribute instance-attribute

broker_dependencies = ()

graceful_timeout class-attribute instance-attribute

graceful_timeout = None

extra_context class-attribute instance-attribute

extra_context = field(default_factory=dict)

add_middleware

add_middleware(middleware)

Source code in faststream/_internal/configs/broker.py

def add_middleware(self, middleware: "BrokerMiddleware[Any]") -> None:
    self.broker_middlewares = (*self.broker_middlewares, middleware)

insert_middleware

insert_middleware(middleware)

Source code in faststream/_internal/configs/broker.py

def insert_middleware(self, middleware: "BrokerMiddleware[Any]") -> None:
    self.broker_middlewares = (middleware, *self.broker_middlewares)