Skip to content

AcknowledgementMiddleware

faststream.middlewares.AcknowledgementMiddleware #

AcknowledgementMiddleware(
    logger: LoggerState,
    ack_policy: AckPolicy,
    fallback_parser: AsyncCallable,
)
Source code in faststream/middlewares/acknowledgement/middleware.py 
26
27
28
29
30
31
32
33
34
def __init__(
    self,
    logger: "LoggerState",
    ack_policy: "AckPolicy",
    fallback_parser: "AsyncCallable",
) -> None:
    self.ack_policy = ack_policy
    self.logger = logger
    self.fallback_parser = fallback_parser

ack_policy instance-attribute #

ack_policy = ack_policy

logger instance-attribute #

logger = logger

fallback_parser instance-attribute #

fallback_parser = fallback_parser