feat/ack_middleware added middleware

docs/docs/SUMMARY.md

@@ -119,6 +119,7 @@ search:
 - [Reference - Code API](api/index.md)
     - Public API
         - faststream
+            - [AckPolicy](public_api/faststream/AckPolicy.md)
             - [BaseMiddleware](public_api/faststream/BaseMiddleware.md)
             - [Context](public_api/faststream/Context.md)
             - [Depends](public_api/faststream/Depends.md)
@@ -205,6 +206,7 @@ search:
                 - [TestRedisBroker](public_api/faststream/redis/TestRedisBroker.md)
     - All API
         - faststream
+            - [AckPolicy](api/faststream/AckPolicy.md)
             - [BaseMiddleware](api/faststream/BaseMiddleware.md)
             - [Context](api/faststream/Context.md)
             - [Depends](api/faststream/Depends.md)
@@ -472,8 +474,15 @@ search:
                     - [encode_message](api/faststream/message/utils/encode_message.md)
                     - [gen_cor_id](api/faststream/message/utils/gen_cor_id.md)
             - middlewares
+                - [AckPolicy](api/faststream/middlewares/AckPolicy.md)
+                - [AcknowledgementMiddleware](api/faststream/middlewares/AcknowledgementMiddleware.md)
                 - [BaseMiddleware](api/faststream/middlewares/BaseMiddleware.md)
                 - [ExceptionMiddleware](api/faststream/middlewares/ExceptionMiddleware.md)
+                - acknowledgement
+                    - conf
+                        - [AckPolicy](api/faststream/middlewares/acknowledgement/conf/AckPolicy.md)
+                    - middleware
+                        - [AcknowledgementMiddleware](api/faststream/middlewares/acknowledgement/middleware/AcknowledgementMiddleware.md)
                 - base
                     - [BaseMiddleware](api/faststream/middlewares/base/BaseMiddleware.md)
                 - exception

docs/docs/en/api/faststream/AckPolicy.md

@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.AckPolicy

docs/docs/en/api/faststream/middlewares/AckPolicy.md

@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.middlewares.AckPolicy

docs/docs/en/api/faststream/middlewares/AcknowledgementMiddleware.md

@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.middlewares.AcknowledgementMiddleware

docs/docs/en/api/faststream/middlewares/acknowledgement/conf/AckPolicy.md

@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.middlewares.acknowledgement.conf.AckPolicy

docs/docs/en/api/faststream/middlewares/acknowledgement/middleware/AcknowledgementMiddleware.md

@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.middlewares.acknowledgement.middleware.AcknowledgementMiddleware

faststream/__init__.py

@@ -4,7 +4,7 @@
 from faststream._internal.utils import apply_types
 from faststream.annotations import ContextRepo, Logger
 from faststream.app import FastStream
-from faststream.middlewares import BaseMiddleware, ExceptionMiddleware
+from faststream.middlewares import AckPolicy, BaseMiddleware, ExceptionMiddleware
 from faststream.params import (
     Context,
     Depends,
@@ -16,6 +16,7 @@
 
 __all__ = (
     # middlewares
+    "AckPolicy",
     "BaseMiddleware",
     # params
     "Context",

faststream/_internal/broker/broker.py

@@ -16,7 +16,6 @@
 from fast_depends.pydantic import PydanticSerializer
 from typing_extensions import Doc, Self
 
-from faststream._internal._compat import is_test_env
 from faststream._internal.constants import EMPTY
 from faststream._internal.context.repository import ContextRepo
 from faststream._internal.setup import (
@@ -164,12 +163,10 @@ def __init__(
         self._connection = None
         self._producer = None
 
-        # TODO: remove useless middleware filter
-        if not is_test_env():
-            self._middlewares = (
-                CriticalLogMiddleware(logger_state),
-                *self._middlewares,
-            )
+        self._middlewares = (
+            CriticalLogMiddleware(logger_state),
+            *self._middlewares,
+        )
 
         self._state = EmptyState(
             depends_params=FastDependsData(