diff --git a/src/Debug/QueueCollector.php b/src/Debug/QueueCollector.php
index 1a8c9d76..d0bc7171 100644
--- a/src/Debug/QueueCollector.php
+++ b/src/Debug/QueueCollector.php
@@ -4,11 +4,11 @@
 
 namespace Yiisoft\Queue\Debug;
 
+use Yiisoft\Queue\Middleware\MiddlewareInterface;
 use Yiisoft\Yii\Debug\Collector\CollectorTrait;
 use Yiisoft\Yii\Debug\Collector\SummaryCollectorInterface;
 use Yiisoft\Queue\Enum\JobStatus;
 use Yiisoft\Queue\Message\MessageInterface;
-use Yiisoft\Queue\Middleware\Push\MiddlewarePushInterface;
 use Yiisoft\Queue\QueueInterface;
 
 final class QueueCollector implements SummaryCollectorInterface
@@ -53,7 +53,7 @@ public function collectStatus(string $id, JobStatus $status): void
     public function collectPush(
         string $channel,
         MessageInterface $message,
-        string|array|callable|MiddlewarePushInterface ...$middlewareDefinitions,
+        string|array|callable|MiddlewareInterface ...$middlewareDefinitions,
     ): void {
         if (!$this->isActive()) {
             return;
diff --git a/src/Debug/QueueDecorator.php b/src/Debug/QueueDecorator.php
index ed174393..20d3c7b8 100644
--- a/src/Debug/QueueDecorator.php
+++ b/src/Debug/QueueDecorator.php
@@ -7,7 +7,7 @@
 use Yiisoft\Queue\Adapter\AdapterInterface;
 use Yiisoft\Queue\Enum\JobStatus;
 use Yiisoft\Queue\Message\MessageInterface;
-use Yiisoft\Queue\Middleware\Push\MiddlewarePushInterface;
+use Yiisoft\Queue\Middleware\MiddlewareInterface;
 use Yiisoft\Queue\QueueInterface;
 
 final class QueueDecorator implements QueueInterface
@@ -28,7 +28,7 @@ public function status(string|int $id): JobStatus
 
     public function push(
         MessageInterface $message,
-        string|array|callable|MiddlewarePushInterface ...$middlewareDefinitions
+        string|array|callable|MiddlewareInterface ...$middlewareDefinitions
     ): MessageInterface {
         $message = $this->queue->push($message, ...$middlewareDefinitions);
         $this->collector->collectPush($this->queue->getChannelName(), $message, ...$middlewareDefinitions);
@@ -61,4 +61,9 @@ public function withChannelName(string $channel): QueueInterface
         $new->queue = $this->queue->withChannelName($channel);
         return $new;
     }
+
+    public function getAdapter(): ?AdapterInterface
+    {
+        return $this->queue->getAdapter();
+    }
 }
diff --git a/src/Middleware/Push/AdapterPushHandler.php b/src/Middleware/AdapterHandler.php
similarity index 66%
rename from src/Middleware/Push/AdapterPushHandler.php
rename to src/Middleware/AdapterHandler.php
index be4b1e67..7564016b 100644
--- a/src/Middleware/Push/AdapterPushHandler.php
+++ b/src/Middleware/AdapterHandler.php
@@ -2,16 +2,16 @@
 
 declare(strict_types=1);
 
-namespace Yiisoft\Queue\Middleware\Push;
+namespace Yiisoft\Queue\Middleware;
 
 use Yiisoft\Queue\Exception\AdapterConfiguration\AdapterNotConfiguredException;
 
 /**
  * @internal
  */
-final class AdapterPushHandler implements MessageHandlerPushInterface
+final class AdapterHandler implements MessageHandlerInterface
 {
-    public function handlePush(PushRequest $request): PushRequest
+    public function handle(Request $request): Request
     {
         if (($adapter = $request->getAdapter()) === null) {
             throw new AdapterNotConfiguredException();
diff --git a/src/Middleware/Consume/ConsumeMiddlewareDispatcher.php b/src/Middleware/Consume/ConsumeMiddlewareDispatcher.php
deleted file mode 100644
index be8de7df..00000000
--- a/src/Middleware/Consume/ConsumeMiddlewareDispatcher.php
+++ /dev/null
@@ -1,100 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Yiisoft\Queue\Middleware\Consume;
-
-use Closure;
-
-final class ConsumeMiddlewareDispatcher
-{
-    /**
-     * Contains a middleware pipeline handler.
-     *
-     * @var MiddlewareConsumeStack|null The middleware stack.
-     */
-    private ?MiddlewareConsumeStack $stack = null;
-
-    /**
-     * @var array[]|callable[]|MiddlewareConsumeInterface[]|string[]
-     */
-    private array $middlewareDefinitions;
-
-    public function __construct(
-        private MiddlewareFactoryConsumeInterface $middlewareFactory,
-        array|callable|string|MiddlewareConsumeInterface ...$middlewareDefinitions,
-    ) {
-        $this->middlewareDefinitions = array_reverse($middlewareDefinitions);
-    }
-
-    /**
-     * Dispatch request through middleware to get response.
-     *
-     * @param ConsumeRequest $request Request to pass to middleware.
-     * @param MessageHandlerConsumeInterface $finishHandler Handler to use in case no middleware produced response.
-     */
-    public function dispatch(
-        ConsumeRequest $request,
-        MessageHandlerConsumeInterface $finishHandler
-    ): ConsumeRequest {
-        if ($this->stack === null) {
-            $this->stack = new MiddlewareConsumeStack($this->buildMiddlewares(), $finishHandler);
-        }
-
-        return $this->stack->handleConsume($request);
-    }
-
-    /**
-     * Returns new instance with middleware handlers replaced with the ones provided.
-     * Last specified handler will be executed first.
-     *
-     * @param array[]|callable[]|MiddlewareConsumeInterface[]|string[] $middlewareDefinitions Each array element is:
-     *
-     * - A name of a middleware class. The middleware instance will be obtained from container executed.
-     * - A callable with `function(ServerRequestInterface $request, RequestHandlerInterface $handler):
-     *     ResponseInterface` signature.
-     * - A "callable-like" array in format `[FooMiddleware::class, 'index']`. `FooMiddleware` instance will
-     *   be created and `index()` method will be executed.
-     * - A function returning a middleware. The middleware returned will be executed.
-     *
-     * For callables typed parameters are automatically injected using dependency injection container.
-     *
-     * @return self New instance of the {@see ConsumeMiddlewareDispatcher}
-     */
-    public function withMiddlewares(array $middlewareDefinitions): self
-    {
-        $instance = clone $this;
-        $instance->middlewareDefinitions = array_reverse($middlewareDefinitions);
-
-        // Fixes a memory leak.
-        unset($instance->stack);
-        $instance->stack = null;
-
-        return $instance;
-    }
-
-    /**
-     * @return bool Whether there are middleware defined in the dispatcher.
-     */
-    public function hasMiddlewares(): bool
-    {
-        return $this->middlewareDefinitions !== [];
-    }
-
-    /**
-     * @return Closure[]
-     */
-    private function buildMiddlewares(): array
-    {
-        $middlewares = [];
-        $factory = $this->middlewareFactory;
-
-        foreach ($this->middlewareDefinitions as $middlewareDefinition) {
-            $middlewares[] = static fn (): MiddlewareConsumeInterface => $factory->createConsumeMiddleware(
-                $middlewareDefinition
-            );
-        }
-
-        return $middlewares;
-    }
-}
diff --git a/src/Middleware/Consume/ConsumeRequest.php b/src/Middleware/Consume/ConsumeRequest.php
deleted file mode 100644
index 489c7d5a..00000000
--- a/src/Middleware/Consume/ConsumeRequest.php
+++ /dev/null
@@ -1,41 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Yiisoft\Queue\Middleware\Consume;
-
-use Yiisoft\Queue\Message\MessageInterface;
-use Yiisoft\Queue\QueueInterface;
-
-final class ConsumeRequest
-{
-    public function __construct(private MessageInterface $message, private QueueInterface $queue)
-    {
-    }
-
-    public function getMessage(): MessageInterface
-    {
-        return $this->message;
-    }
-
-    public function getQueue(): QueueInterface
-    {
-        return $this->queue;
-    }
-
-    public function withMessage(MessageInterface $message): self
-    {
-        $instance = clone $this;
-        $instance->message = $message;
-
-        return $instance;
-    }
-
-    public function withQueue(QueueInterface $queue): self
-    {
-        $instance = clone $this;
-        $instance->queue = $queue;
-
-        return $instance;
-    }
-}
diff --git a/src/Middleware/Consume/MessageHandlerConsumeInterface.php b/src/Middleware/Consume/MessageHandlerConsumeInterface.php
deleted file mode 100644
index 832d5896..00000000
--- a/src/Middleware/Consume/MessageHandlerConsumeInterface.php
+++ /dev/null
@@ -1,10 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Yiisoft\Queue\Middleware\Consume;
-
-interface MessageHandlerConsumeInterface
-{
-    public function handleConsume(ConsumeRequest $request): ConsumeRequest;
-}
diff --git a/src/Middleware/Consume/MiddlewareConsumeInterface.php b/src/Middleware/Consume/MiddlewareConsumeInterface.php
deleted file mode 100644
index d3ec4c2f..00000000
--- a/src/Middleware/Consume/MiddlewareConsumeInterface.php
+++ /dev/null
@@ -1,10 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Yiisoft\Queue\Middleware\Consume;
-
-interface MiddlewareConsumeInterface
-{
-    public function processConsume(ConsumeRequest $request, MessageHandlerConsumeInterface $handler): ConsumeRequest;
-}
diff --git a/src/Middleware/Consume/MiddlewareConsumeStack.php b/src/Middleware/Consume/MiddlewareConsumeStack.php
deleted file mode 100644
index 935594c6..00000000
--- a/src/Middleware/Consume/MiddlewareConsumeStack.php
+++ /dev/null
@@ -1,75 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Yiisoft\Queue\Middleware\Consume;
-
-use Closure;
-
-final class MiddlewareConsumeStack implements MessageHandlerConsumeInterface
-{
-    /**
-     * Contains a stack of middleware wrapped in handlers.
-     * Each handler points to the handler of middleware that will be processed next.
-     *
-     * @var MessageHandlerConsumeInterface|null stack of middleware
-     */
-    private ?MessageHandlerConsumeInterface $stack = null;
-
-    /**
-     * @param Closure[] $middlewares Middlewares.
-     * @param MessageHandlerConsumeInterface $finishHandler Fallback handler
-     * events.
-     */
-    public function __construct(
-        private array $middlewares,
-        private MessageHandlerConsumeInterface $finishHandler,
-    ) {
-    }
-
-    public function handleConsume(ConsumeRequest $request): ConsumeRequest
-    {
-        if ($this->stack === null) {
-            $this->build();
-        }
-
-        /** @psalm-suppress PossiblyNullReference */
-        return $this->stack->handleConsume($request);
-    }
-
-    private function build(): void
-    {
-        $handler = $this->finishHandler;
-
-        foreach ($this->middlewares as $middleware) {
-            $handler = $this->wrap($middleware, $handler);
-        }
-
-        $this->stack = $handler;
-    }
-
-    /**
-     * Wrap handler by middlewares.
-     */
-    private function wrap(Closure $middlewareFactory, MessageHandlerConsumeInterface $handler): MessageHandlerConsumeInterface
-    {
-        return new class ($middlewareFactory, $handler) implements MessageHandlerConsumeInterface {
-            private ?MiddlewareConsumeInterface $middleware = null;
-
-            public function __construct(
-                private Closure $middlewareFactory,
-                private MessageHandlerConsumeInterface $handler,
-            ) {
-            }
-
-            public function handleConsume(ConsumeRequest $request): ConsumeRequest
-            {
-                if ($this->middleware === null) {
-                    $this->middleware = ($this->middlewareFactory)();
-                }
-
-                return $this->middleware->processConsume($request, $this->handler);
-            }
-        };
-    }
-}
diff --git a/src/Middleware/Consume/MiddlewareFactoryConsume.php b/src/Middleware/Consume/MiddlewareFactoryConsume.php
deleted file mode 100644
index e5561b37..00000000
--- a/src/Middleware/Consume/MiddlewareFactoryConsume.php
+++ /dev/null
@@ -1,155 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Yiisoft\Queue\Middleware\Consume;
-
-use Closure;
-use Psr\Container\ContainerInterface;
-use Yiisoft\Definitions\ArrayDefinition;
-use Yiisoft\Definitions\Exception\InvalidConfigException;
-use Yiisoft\Definitions\Helpers\DefinitionValidator;
-use Yiisoft\Injector\Injector;
-use Yiisoft\Queue\Middleware\CallableFactory;
-use Yiisoft\Queue\Middleware\InvalidCallableConfigurationException;
-use Yiisoft\Queue\Middleware\InvalidMiddlewareDefinitionException;
-
-use function is_string;
-
-/**
- * Creates a middleware based on the definition provided.
- */
-final class MiddlewareFactoryConsume implements MiddlewareFactoryConsumeInterface
-{
-    /**
-     * @param ContainerInterface $container Container to use for resolving definitions.
-     */
-    public function __construct(
-        private ContainerInterface $container,
-        private CallableFactory $callableFactory,
-    ) {
-    }
-
-    /**
-     * @param array|callable|MiddlewareConsumeInterface|string $middlewareDefinition Middleware definition in one of the
-     *     following formats:
-     *
-     * - A middleware object.
-     * - A name of a middleware class. The middleware instance will be obtained from container and executed.
-     * - A callable with `function(ServerRequestInterface $request, RequestHandlerInterface $handler):
-     *     ResponseInterface` signature.
-     * - A controller handler action in format `[TestController::class, 'index']`. `TestController` instance will
-     *   be created and `index()` method will be executed.
-     * - A function returning a middleware. The middleware returned will be executed.
-     *
-     * For handler action and callable
-     * typed parameters are automatically injected using dependency injection container.
-     * Current request and handler could be obtained by type-hinting for {@see ServerRequestInterface}
-     * and {@see RequestHandlerInterface}.
-     *
-     * @throws InvalidMiddlewareDefinitionException
-     *
-     * @return MiddlewareConsumeInterface
-     */
-    public function createConsumeMiddleware(
-        MiddlewareConsumeInterface|callable|array|string $middlewareDefinition
-    ): MiddlewareConsumeInterface {
-        if ($middlewareDefinition instanceof MiddlewareConsumeInterface) {
-            return $middlewareDefinition;
-        }
-
-        if (is_string($middlewareDefinition)) {
-            return $this->getFromContainer($middlewareDefinition);
-        }
-
-        return $this->tryGetFromCallable($middlewareDefinition)
-            ?? $this->tryGetFromArrayDefinition($middlewareDefinition)
-            ?? throw new InvalidMiddlewareDefinitionException($middlewareDefinition);
-    }
-
-    private function getFromContainer(string $middlewareDefinition): MiddlewareConsumeInterface
-    {
-        if (class_exists($middlewareDefinition)) {
-            if (is_subclass_of($middlewareDefinition, MiddlewareConsumeInterface::class)) {
-                /** @var MiddlewareConsumeInterface */
-                return $this->container->get($middlewareDefinition);
-            }
-        } elseif ($this->container->has($middlewareDefinition)) {
-            $middleware = $this->container->get($middlewareDefinition);
-            if ($middleware instanceof MiddlewareConsumeInterface) {
-                return $middleware;
-            }
-        }
-
-        throw new InvalidMiddlewareDefinitionException($middlewareDefinition);
-    }
-
-    private function wrapCallable(callable $callback): MiddlewareConsumeInterface
-    {
-        return new class ($callback, $this->container) implements MiddlewareConsumeInterface {
-            private $callback;
-
-            public function __construct(callable $callback, private ContainerInterface $container)
-            {
-                $this->callback = $callback;
-            }
-
-            public function processConsume(ConsumeRequest $request, MessageHandlerConsumeInterface $handler): ConsumeRequest
-            {
-                $response = (new Injector($this->container))->invoke($this->callback, [$request, $handler]);
-                if ($response instanceof ConsumeRequest) {
-                    return $response;
-                }
-
-                if ($response instanceof MiddlewareConsumeInterface) {
-                    return $response->processConsume($request, $handler);
-                }
-
-                throw new InvalidMiddlewareDefinitionException($this->callback);
-            }
-        };
-    }
-
-    private function tryGetFromCallable(
-        callable|MiddlewareConsumeInterface|array|string $definition
-    ): ?MiddlewareConsumeInterface {
-        if ($definition instanceof Closure) {
-            return $this->wrapCallable($definition);
-        }
-
-        if (
-            is_array($definition)
-            && array_keys($definition) === [0, 1]
-        ) {
-            try {
-                return $this->wrapCallable($this->callableFactory->create($definition));
-            } catch (InvalidCallableConfigurationException $exception) {
-                throw new InvalidMiddlewareDefinitionException($definition, previous: $exception);
-            }
-        } else {
-            return null;
-        }
-    }
-
-    private function tryGetFromArrayDefinition(
-        callable|MiddlewareConsumeInterface|array|string $definition
-    ): ?MiddlewareConsumeInterface {
-        if (!is_array($definition)) {
-            return null;
-        }
-
-        try {
-            DefinitionValidator::validateArrayDefinition($definition);
-
-            $middleware = ArrayDefinition::fromConfig($definition)->resolve($this->container);
-            if ($middleware instanceof MiddlewareConsumeInterface) {
-                return $middleware;
-            }
-
-            throw new InvalidMiddlewareDefinitionException($definition);
-        } catch (InvalidConfigException) {
-        }
-
-        throw new InvalidMiddlewareDefinitionException($definition);
-    }
-}
diff --git a/src/Middleware/Consume/MiddlewareFactoryConsumeInterface.php b/src/Middleware/Consume/MiddlewareFactoryConsumeInterface.php
deleted file mode 100644
index 70f20cf2..00000000
--- a/src/Middleware/Consume/MiddlewareFactoryConsumeInterface.php
+++ /dev/null
@@ -1,22 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Yiisoft\Queue\Middleware\Consume;
-
-/**
- * Creates a middleware based on the definition provided.
- * You may implement this interface if you want to introduce custom definitions or pass additional data to
- * the middleware created.
- */
-interface MiddlewareFactoryConsumeInterface
-{
-    /**
-     * Create a middleware based on definition provided.
-     *
-     * @param array|callable|MiddlewareConsumeInterface|string $middlewareDefinition Middleware definition to use.
-     *
-     * @return MiddlewareConsumeInterface
-     */
-    public function createConsumeMiddleware(callable|array|string|MiddlewareConsumeInterface $middlewareDefinition): MiddlewareConsumeInterface;
-}
diff --git a/src/Middleware/Consume/ConsumeFinalHandler.php b/src/Middleware/ConsumeFinalHandler.php
similarity index 57%
rename from src/Middleware/Consume/ConsumeFinalHandler.php
rename to src/Middleware/ConsumeFinalHandler.php
index e3d281ef..16e2f2df 100644
--- a/src/Middleware/Consume/ConsumeFinalHandler.php
+++ b/src/Middleware/ConsumeFinalHandler.php
@@ -2,20 +2,20 @@
 
 declare(strict_types=1);
 
-namespace Yiisoft\Queue\Middleware\Consume;
+namespace Yiisoft\Queue\Middleware;
 
 use Closure;
 
 /**
  * @internal
  */
-final class ConsumeFinalHandler implements MessageHandlerConsumeInterface
+final class ConsumeFinalHandler implements MessageHandlerInterface
 {
     public function __construct(private Closure $handler)
     {
     }
 
-    public function handleConsume(ConsumeRequest $request): ConsumeRequest
+    public function handle(Request $request): Request
     {
         $handler = $this->handler;
         $handler($request->getMessage());
diff --git a/src/Middleware/Push/Implementation/DelayMiddlewareInterface.php b/src/Middleware/DelayMiddlewareInterface.php
similarity index 69%
rename from src/Middleware/Push/Implementation/DelayMiddlewareInterface.php
rename to src/Middleware/DelayMiddlewareInterface.php
index bd52a52e..6f99d4cc 100644
--- a/src/Middleware/Push/Implementation/DelayMiddlewareInterface.php
+++ b/src/Middleware/DelayMiddlewareInterface.php
@@ -2,14 +2,12 @@
 
 declare(strict_types=1);
 
-namespace Yiisoft\Queue\Middleware\Push\Implementation;
-
-use Yiisoft\Queue\Middleware\Push\MiddlewarePushInterface;
+namespace Yiisoft\Queue\Middleware;
 
 /**
  * A middleware interface for message delaying. It must be implemented in an adapter package or in a project.
  */
-interface DelayMiddlewareInterface extends MiddlewarePushInterface
+interface DelayMiddlewareInterface extends MiddlewareInterface
 {
     /**
      * Set a new delay value into the middleware object
diff --git a/src/Middleware/FailureHandling/FailureFinalHandler.php b/src/Middleware/FailureHandling/FailureFinalHandler.php
index f9668231..9d67728f 100644
--- a/src/Middleware/FailureHandling/FailureFinalHandler.php
+++ b/src/Middleware/FailureHandling/FailureFinalHandler.php
@@ -16,6 +16,7 @@ final class FailureFinalHandler implements MessageFailureHandlerInterface
      */
     public function handleFailure(FailureHandlingRequest $request): FailureHandlingRequest
     {
-        throw $request->getException();
+        // TODO: Add tests
+        throw $request->getException() ?? new \RuntimeException('Message processing failed.');
     }
 }
diff --git a/src/Middleware/FailureHandling/FailureHandlingRequest.php b/src/Middleware/FailureHandling/FailureHandlingRequest.php
index 43de7433..922e9b83 100644
--- a/src/Middleware/FailureHandling/FailureHandlingRequest.php
+++ b/src/Middleware/FailureHandling/FailureHandlingRequest.php
@@ -10,7 +10,7 @@
 
 final class FailureHandlingRequest
 {
-    public function __construct(private MessageInterface $message, private Throwable $exception, private QueueInterface $queue)
+    public function __construct(private MessageInterface $message, private ?Throwable $exception, private QueueInterface $queue)
     {
     }
 
@@ -22,7 +22,7 @@ public function getMessage(): MessageInterface
         return $this->message;
     }
 
-    public function getException(): Throwable
+    public function getException(): ?Throwable
     {
         return $this->exception;
     }
diff --git a/src/Middleware/FailureHandling/Implementation/ExponentialDelayMiddleware.php b/src/Middleware/FailureHandling/Implementation/ExponentialDelayMiddleware.php
index 07d0f640..72d92bac 100644
--- a/src/Middleware/FailureHandling/Implementation/ExponentialDelayMiddleware.php
+++ b/src/Middleware/FailureHandling/Implementation/ExponentialDelayMiddleware.php
@@ -5,12 +5,11 @@
 namespace Yiisoft\Queue\Middleware\FailureHandling\Implementation;
 
 use InvalidArgumentException;
-use Yiisoft\Queue\Message\Message;
 use Yiisoft\Queue\Message\MessageInterface;
+use Yiisoft\Queue\Middleware\DelayMiddlewareInterface;
 use Yiisoft\Queue\Middleware\FailureHandling\FailureHandlingRequest;
 use Yiisoft\Queue\Middleware\FailureHandling\MessageFailureHandlerInterface;
 use Yiisoft\Queue\Middleware\FailureHandling\MiddlewareFailureInterface;
-use Yiisoft\Queue\Middleware\Push\Implementation\DelayMiddlewareInterface;
 use Yiisoft\Queue\QueueInterface;
 use Yiisoft\Queue\Middleware\FailureHandling\FailureEnvelope;
 
diff --git a/src/Middleware/MessageHandlerInterface.php b/src/Middleware/MessageHandlerInterface.php
new file mode 100644
index 00000000..1191b63f
--- /dev/null
+++ b/src/Middleware/MessageHandlerInterface.php
@@ -0,0 +1,10 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Yiisoft\Queue\Middleware;
+
+interface MessageHandlerInterface
+{
+    public function handle(Request $request): Request;
+}
diff --git a/src/Middleware/Push/PushMiddlewareDispatcher.php b/src/Middleware/MiddlewareDispatcher.php
similarity index 67%
rename from src/Middleware/Push/PushMiddlewareDispatcher.php
rename to src/Middleware/MiddlewareDispatcher.php
index 489dabab..048449e5 100644
--- a/src/Middleware/Push/PushMiddlewareDispatcher.php
+++ b/src/Middleware/MiddlewareDispatcher.php
@@ -2,26 +2,26 @@
 
 declare(strict_types=1);
 
-namespace Yiisoft\Queue\Middleware\Push;
+namespace Yiisoft\Queue\Middleware;
 
 use Closure;
 
-final class PushMiddlewareDispatcher
+final class MiddlewareDispatcher
 {
     /**
      * Contains a middleware pipeline handler.
      *
-     * @var MiddlewarePushStack|null The middleware stack.
+     * @var MiddlewareStack|null The middleware stack.
      */
-    private ?MiddlewarePushStack $stack = null;
+    private ?MiddlewareStack $stack = null;
     /**
-     * @var array[]|callable[]|MiddlewarePushInterface[]|string[]
+     * @var array[]|callable[]|MiddlewareInterface[]|string[]
      */
     private array $middlewareDefinitions;
 
     public function __construct(
-        private MiddlewareFactoryPushInterface $middlewareFactory,
-        array|callable|string|MiddlewarePushInterface ...$middlewareDefinitions,
+        private MiddlewareFactoryInterface $middlewareFactory,
+        array|callable|string|MiddlewareInterface ...$middlewareDefinitions,
     ) {
         $this->middlewareDefinitions = array_reverse($middlewareDefinitions);
     }
@@ -29,25 +29,25 @@ public function __construct(
     /**
      * Dispatch request through middleware to get response.
      *
-     * @param PushRequest $request Request to pass to middleware.
-     * @param MessageHandlerPushInterface $finishHandler Handler to use in case no middleware produced response.
+     * @param Request $request Request to pass to middleware.
+     * @param MessageHandlerInterface $finishHandler Handler to use in case no middleware produced response.
      */
     public function dispatch(
-        PushRequest $request,
-        MessageHandlerPushInterface $finishHandler
-    ): PushRequest {
+        Request $request,
+        MessageHandlerInterface $finishHandler
+    ): Request {
         if ($this->stack === null) {
-            $this->stack = new MiddlewarePushStack($this->buildMiddlewares(), $finishHandler);
+            $this->stack = new MiddlewareStack($this->buildMiddlewares(), $finishHandler);
         }
 
-        return $this->stack->handlePush($request);
+        return $this->stack->handle($request);
     }
 
     /**
      * Returns new instance with middleware handlers replaced with the ones provided.
      * Last specified handler will be executed first.
      *
-     * @param array[]|callable[]|MiddlewarePushInterface[]|string[] $middlewareDefinitions Each array element is:
+     * @param array[]|callable[]|MiddlewareInterface[]|string[] $middlewareDefinitions Each array element is:
      *
      * - A name of a middleware class. The middleware instance will be obtained from container executed.
      * - A callable with `function(ServerRequestInterface $request, RequestHandlerInterface $handler):
@@ -89,7 +89,7 @@ private function buildMiddlewares(): array
         $factory = $this->middlewareFactory;
 
         foreach ($this->middlewareDefinitions as $middlewareDefinition) {
-            $middlewares[] = static fn (): MiddlewarePushInterface => $factory->createPushMiddleware(
+            $middlewares[] = static fn (): MiddlewareInterface => $factory->createMiddleware(
                 $middlewareDefinition
             );
         }
diff --git a/src/Middleware/Push/MiddlewareFactoryPush.php b/src/Middleware/MiddlewareFactory.php
similarity index 74%
rename from src/Middleware/Push/MiddlewareFactoryPush.php
rename to src/Middleware/MiddlewareFactory.php
index 8e235b36..06449391 100644
--- a/src/Middleware/Push/MiddlewareFactoryPush.php
+++ b/src/Middleware/MiddlewareFactory.php
@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Yiisoft\Queue\Middleware\Push;
+namespace Yiisoft\Queue\Middleware;
 
 use Closure;
 use Psr\Container\ContainerInterface;
@@ -10,16 +10,13 @@
 use Yiisoft\Definitions\Exception\InvalidConfigException;
 use Yiisoft\Definitions\Helpers\DefinitionValidator;
 use Yiisoft\Injector\Injector;
-use Yiisoft\Queue\Middleware\CallableFactory;
-use Yiisoft\Queue\Middleware\InvalidCallableConfigurationException;
-use Yiisoft\Queue\Middleware\InvalidMiddlewareDefinitionException;
 
 use function is_string;
 
 /**
  * Creates a middleware based on the definition provided.
  */
-final class MiddlewareFactoryPush implements MiddlewareFactoryPushInterface
+final class MiddlewareFactory implements MiddlewareFactoryInterface
 {
     /**
      * @param ContainerInterface $container Container to use for resolving definitions.
@@ -31,7 +28,7 @@ public function __construct(
     }
 
     /**
-     * @param array|callable|MiddlewarePushInterface|string $middlewareDefinition Middleware definition in one of the
+     * @param array|callable|MiddlewareInterface|string $middlewareDefinition Middleware definition in one of the
      *     following formats:
      *
      * - A middleware object.
@@ -49,12 +46,12 @@ public function __construct(
      *
      * @throws InvalidMiddlewareDefinitionException
      *
-     * @return MiddlewarePushInterface
+     * @return MiddlewareInterface
      */
-    public function createPushMiddleware(
-        MiddlewarePushInterface|callable|array|string $middlewareDefinition
-    ): MiddlewarePushInterface {
-        if ($middlewareDefinition instanceof MiddlewarePushInterface) {
+    public function createMiddleware(
+        MiddlewareInterface|callable|array|string $middlewareDefinition
+    ): MiddlewareInterface {
+        if ($middlewareDefinition instanceof MiddlewareInterface) {
             return $middlewareDefinition;
         }
 
@@ -67,16 +64,16 @@ public function createPushMiddleware(
             ?? throw new InvalidMiddlewareDefinitionException($middlewareDefinition);
     }
 
-    private function getFromContainer(string $middlewareDefinition): MiddlewarePushInterface
+    private function getFromContainer(string $middlewareDefinition): MiddlewareInterface
     {
         if (class_exists($middlewareDefinition)) {
-            if (is_subclass_of($middlewareDefinition, MiddlewarePushInterface::class)) {
-                /** @var MiddlewarePushInterface */
+            if (is_subclass_of($middlewareDefinition, MiddlewareInterface::class)) {
+                /** @var MiddlewareInterface */
                 return $this->container->get($middlewareDefinition);
             }
         } elseif ($this->container->has($middlewareDefinition)) {
             $middleware = $this->container->get($middlewareDefinition);
-            if ($middleware instanceof MiddlewarePushInterface) {
+            if ($middleware instanceof MiddlewareInterface) {
                 return $middleware;
             }
         }
@@ -84,9 +81,9 @@ private function getFromContainer(string $middlewareDefinition): MiddlewarePushI
         throw new InvalidMiddlewareDefinitionException($middlewareDefinition);
     }
 
-    private function wrapCallable(callable $callback): MiddlewarePushInterface
+    private function wrapCallable(callable $callback): MiddlewareInterface
     {
-        return new class ($callback, $this->container) implements MiddlewarePushInterface {
+        return new class ($callback, $this->container) implements MiddlewareInterface {
             private $callback;
 
             public function __construct(callable $callback, private ContainerInterface $container)
@@ -94,15 +91,15 @@ public function __construct(callable $callback, private ContainerInterface $cont
                 $this->callback = $callback;
             }
 
-            public function processPush(PushRequest $request, MessageHandlerPushInterface $handler): PushRequest
+            public function process(Request $request, MessageHandlerInterface $handler): Request
             {
                 $response = (new Injector($this->container))->invoke($this->callback, [$request, $handler]);
-                if ($response instanceof PushRequest) {
+                if ($response instanceof Request) {
                     return $response;
                 }
 
-                if ($response instanceof MiddlewarePushInterface) {
-                    return $response->processPush($request, $handler);
+                if ($response instanceof MiddlewareInterface) {
+                    return $response->process($request, $handler);
                 }
 
                 throw new InvalidMiddlewareDefinitionException($this->callback);
@@ -111,8 +108,8 @@ public function processPush(PushRequest $request, MessageHandlerPushInterface $h
     }
 
     private function tryGetFromCallable(
-        callable|MiddlewarePushInterface|array|string $definition
-    ): ?MiddlewarePushInterface {
+        callable|MiddlewareInterface|array|string $definition
+    ): ?MiddlewareInterface {
         if ($definition instanceof Closure) {
             return $this->wrapCallable($definition);
         }
@@ -132,8 +129,8 @@ private function tryGetFromCallable(
     }
 
     private function tryGetFromArrayDefinition(
-        callable|MiddlewarePushInterface|array|string $definition
-    ): ?MiddlewarePushInterface {
+        callable|MiddlewareInterface|array|string $definition
+    ): ?MiddlewareInterface {
         if (!is_array($definition)) {
             return null;
         }
@@ -142,7 +139,7 @@ private function tryGetFromArrayDefinition(
             DefinitionValidator::validateArrayDefinition($definition);
 
             $middleware = ArrayDefinition::fromConfig($definition)->resolve($this->container);
-            if ($middleware instanceof MiddlewarePushInterface) {
+            if ($middleware instanceof MiddlewareInterface) {
                 return $middleware;
             }
 
diff --git a/src/Middleware/MiddlewareFactoryInterface.php b/src/Middleware/MiddlewareFactoryInterface.php
new file mode 100644
index 00000000..6a445062
--- /dev/null
+++ b/src/Middleware/MiddlewareFactoryInterface.php
@@ -0,0 +1,22 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Yiisoft\Queue\Middleware;
+
+/**
+ * Creates a middleware based on the definition provided.
+ * You may implement this interface if you want to introduce custom definitions or pass additional data to
+ * the middleware created.
+ */
+interface MiddlewareFactoryInterface
+{
+    /**
+     * Create a middleware based on definition provided.
+     *
+     * @param array|callable|MiddlewareInterface|string $middlewareDefinition Middleware definition to use.
+     *
+     * @return MiddlewareInterface
+     */
+    public function createMiddleware(callable|array|string|MiddlewareInterface $middlewareDefinition): MiddlewareInterface;
+}
diff --git a/src/Middleware/MiddlewareInterface.php b/src/Middleware/MiddlewareInterface.php
new file mode 100644
index 00000000..77bbc500
--- /dev/null
+++ b/src/Middleware/MiddlewareInterface.php
@@ -0,0 +1,10 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Yiisoft\Queue\Middleware;
+
+interface MiddlewareInterface
+{
+    public function process(Request $request, MessageHandlerInterface $handler): Request;
+}
diff --git a/src/Middleware/Push/MiddlewarePushStack.php b/src/Middleware/MiddlewareStack.php
similarity index 59%
rename from src/Middleware/Push/MiddlewarePushStack.php
rename to src/Middleware/MiddlewareStack.php
index 5682cfc9..e16acb5c 100644
--- a/src/Middleware/Push/MiddlewarePushStack.php
+++ b/src/Middleware/MiddlewareStack.php
@@ -2,39 +2,39 @@
 
 declare(strict_types=1);
 
-namespace Yiisoft\Queue\Middleware\Push;
+namespace Yiisoft\Queue\Middleware;
 
 use Closure;
 
-final class MiddlewarePushStack implements MessageHandlerPushInterface
+final class MiddlewareStack implements MessageHandlerInterface
 {
     /**
      * Contains a stack of middleware wrapped in handlers.
      * Each handler points to the handler of middleware that will be processed next.
      *
-     * @var MessageHandlerPushInterface|null stack of middleware
+     * @var MessageHandlerInterface|null stack of middleware
      */
-    private ?MessageHandlerPushInterface $stack = null;
+    private ?MessageHandlerInterface $stack = null;
 
     /**
      * @param Closure[] $middlewares Middlewares.
-     * @param MessageHandlerPushInterface $finishHandler Fallback handler
+     * @param MessageHandlerInterface $finishHandler Fallback handler
      * events.
      */
     public function __construct(
         private array $middlewares,
-        private MessageHandlerPushInterface $finishHandler,
+        private MessageHandlerInterface $finishHandler,
     ) {
     }
 
-    public function handlePush(PushRequest $request): PushRequest
+    public function handle(Request $request): Request
     {
         if ($this->stack === null) {
             $this->build();
         }
 
         /** @psalm-suppress PossiblyNullReference */
-        return $this->stack->handlePush($request);
+        return $this->stack->handle($request);
     }
 
     private function build(): void
@@ -51,24 +51,24 @@ private function build(): void
     /**
      * Wrap handler by middlewares.
      */
-    private function wrap(Closure $middlewareFactory, MessageHandlerPushInterface $handler): MessageHandlerPushInterface
+    private function wrap(Closure $middlewareFactory, MessageHandlerInterface $handler): MessageHandlerInterface
     {
-        return new class ($middlewareFactory, $handler) implements MessageHandlerPushInterface {
-            private ?MiddlewarePushInterface $middleware = null;
+        return new class ($middlewareFactory, $handler) implements MessageHandlerInterface {
+            private ?MiddlewareInterface $middleware = null;
 
             public function __construct(
                 private Closure $middlewareFactory,
-                private MessageHandlerPushInterface $handler,
+                private MessageHandlerInterface $handler,
             ) {
             }
 
-            public function handlePush(PushRequest $request): PushRequest
+            public function handle(Request $request): Request
             {
                 if ($this->middleware === null) {
                     $this->middleware = ($this->middlewareFactory)();
                 }
 
-                return $this->middleware->processPush($request, $this->handler);
+                return $this->middleware->process($request, $this->handler);
             }
         };
     }
diff --git a/src/Middleware/Push/MessageHandlerPushInterface.php b/src/Middleware/Push/MessageHandlerPushInterface.php
deleted file mode 100644
index 8db45bff..00000000
--- a/src/Middleware/Push/MessageHandlerPushInterface.php
+++ /dev/null
@@ -1,10 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Yiisoft\Queue\Middleware\Push;
-
-interface MessageHandlerPushInterface
-{
-    public function handlePush(PushRequest $request): PushRequest;
-}
diff --git a/src/Middleware/Push/MiddlewareFactoryPushInterface.php b/src/Middleware/Push/MiddlewareFactoryPushInterface.php
deleted file mode 100644
index 6e834f2a..00000000
--- a/src/Middleware/Push/MiddlewareFactoryPushInterface.php
+++ /dev/null
@@ -1,22 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Yiisoft\Queue\Middleware\Push;
-
-/**
- * Creates a middleware based on the definition provided.
- * You may implement this interface if you want to introduce custom definitions or pass additional data to
- * the middleware created.
- */
-interface MiddlewareFactoryPushInterface
-{
-    /**
-     * Create a middleware based on definition provided.
-     *
-     * @param array|callable|MiddlewarePushInterface|string $middlewareDefinition Middleware definition to use.
-     *
-     * @return MiddlewarePushInterface
-     */
-    public function createPushMiddleware(callable|array|string|MiddlewarePushInterface $middlewareDefinition): MiddlewarePushInterface;
-}
diff --git a/src/Middleware/Push/MiddlewarePushInterface.php b/src/Middleware/Push/MiddlewarePushInterface.php
deleted file mode 100644
index 99cc85ca..00000000
--- a/src/Middleware/Push/MiddlewarePushInterface.php
+++ /dev/null
@@ -1,10 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Yiisoft\Queue\Middleware\Push;
-
-interface MiddlewarePushInterface
-{
-    public function processPush(PushRequest $request, MessageHandlerPushInterface $handler): PushRequest;
-}
diff --git a/src/Middleware/Push/PushRequest.php b/src/Middleware/Request.php
similarity index 92%
rename from src/Middleware/Push/PushRequest.php
rename to src/Middleware/Request.php
index 98b72429..0b93b2df 100644
--- a/src/Middleware/Push/PushRequest.php
+++ b/src/Middleware/Request.php
@@ -2,12 +2,12 @@
 
 declare(strict_types=1);
 
-namespace Yiisoft\Queue\Middleware\Push;
+namespace Yiisoft\Queue\Middleware;
 
 use Yiisoft\Queue\Adapter\AdapterInterface;
 use Yiisoft\Queue\Message\MessageInterface;
 
-final class PushRequest
+final class Request
 {
     public function __construct(private MessageInterface $message, private ?AdapterInterface $adapter)
     {
diff --git a/src/Queue.php b/src/Queue.php
index ad8ea76b..2fec5986 100644
--- a/src/Queue.php
+++ b/src/Queue.php
@@ -10,33 +10,33 @@
 use Yiisoft\Queue\Enum\JobStatus;
 use Yiisoft\Queue\Exception\AdapterConfiguration\AdapterNotConfiguredException;
 use Yiisoft\Queue\Message\MessageInterface;
-use Yiisoft\Queue\Middleware\Push\AdapterPushHandler;
-use Yiisoft\Queue\Middleware\Push\MessageHandlerPushInterface;
-use Yiisoft\Queue\Middleware\Push\MiddlewarePushInterface;
-use Yiisoft\Queue\Middleware\Push\PushMiddlewareDispatcher;
-use Yiisoft\Queue\Middleware\Push\PushRequest;
+use Yiisoft\Queue\Middleware\AdapterHandler;
+use Yiisoft\Queue\Middleware\MessageHandlerInterface;
+use Yiisoft\Queue\Middleware\MiddlewareInterface;
+use Yiisoft\Queue\Middleware\MiddlewareDispatcher;
+use Yiisoft\Queue\Middleware\Request;
 use Yiisoft\Queue\Worker\WorkerInterface;
 use Yiisoft\Queue\Message\IdEnvelope;
 
 final class Queue implements QueueInterface
 {
     /**
-     * @var array|array[]|callable[]|MiddlewarePushInterface[]|string[]
+     * @var array|array[]|callable[]|MiddlewareInterface[]|string[]
      */
     private array $middlewareDefinitions;
-    private AdapterPushHandler $adapterPushHandler;
+    private AdapterHandler $adapterHandler;
 
     public function __construct(
         private WorkerInterface $worker,
         private LoopInterface $loop,
         private LoggerInterface $logger,
-        private PushMiddlewareDispatcher $pushMiddlewareDispatcher,
+        private MiddlewareDispatcher $pushMiddlewareDispatcher,
         private ?AdapterInterface $adapter = null,
         private string $channelName = QueueFactoryInterface::DEFAULT_CHANNEL_NAME,
-        MiddlewarePushInterface|callable|array|string ...$middlewareDefinitions
+        MiddlewareInterface|callable|array|string ...$middlewareDefinitions
     ) {
         $this->middlewareDefinitions = $middlewareDefinitions;
-        $this->adapterPushHandler = new AdapterPushHandler();
+        $this->adapterHandler = new AdapterHandler();
     }
 
     public function getChannelName(): string
@@ -46,16 +46,16 @@ public function getChannelName(): string
 
     public function push(
         MessageInterface $message,
-        MiddlewarePushInterface|callable|array|string ...$middlewareDefinitions
+        MiddlewareInterface|callable|array|string ...$middlewareDefinitions
     ): MessageInterface {
         $this->logger->debug(
             'Preparing to push message with handler name "{handlerName}".',
             ['handlerName' => $message->getHandlerName()]
         );
 
-        $request = new PushRequest($message, $this->adapter);
+        $request = new Request($message, $this->adapter);
         $message = $this->pushMiddlewareDispatcher
-            ->dispatch($request, $this->createPushHandler($middlewareDefinitions))
+            ->dispatch($request, $this->createHandler($middlewareDefinitions))
             ->getMessage();
 
         $messageId = $message->getMetadata()[IdEnvelope::MESSAGE_ID_KEY] ?? 'null';
@@ -120,7 +120,12 @@ public function withAdapter(AdapterInterface $adapter): self
         return $new;
     }
 
-    public function withMiddlewares(MiddlewarePushInterface|callable|array|string ...$middlewareDefinitions): self
+    public function getAdapter(): ?AdapterInterface
+    {
+        return $this->adapter;
+    }
+
+    public function withMiddlewares(MiddlewareInterface|callable|array|string ...$middlewareDefinitions): self
     {
         $instance = clone $this;
         $instance->middlewareDefinitions = $middlewareDefinitions;
@@ -128,7 +133,7 @@ public function withMiddlewares(MiddlewarePushInterface|callable|array|string ..
         return $instance;
     }
 
-    public function withMiddlewaresAdded(MiddlewarePushInterface|callable|array|string ...$middlewareDefinitions): self
+    public function withMiddlewaresAdded(MiddlewareInterface|callable|array|string ...$middlewareDefinitions): self
     {
         $instance = clone $this;
         $instance->middlewareDefinitions = [...array_values($instance->middlewareDefinitions), ...array_values($middlewareDefinitions)];
@@ -158,25 +163,25 @@ private function checkAdapter(): void
         }
     }
 
-    private function createPushHandler(array $middlewares): MessageHandlerPushInterface
+    private function createHandler(array $middlewares): MessageHandlerInterface
     {
         return new class (
-            $this->adapterPushHandler,
+            $this->adapterHandler,
             $this->pushMiddlewareDispatcher,
             array_merge($this->middlewareDefinitions, $middlewares)
-        ) implements MessageHandlerPushInterface {
+        ) implements MessageHandlerInterface {
             public function __construct(
-                private AdapterPushHandler $adapterPushHandler,
-                private PushMiddlewareDispatcher $dispatcher,
+                private AdapterHandler $adapterHandler,
+                private MiddlewareDispatcher $dispatcher,
                 private array $middlewares,
             ) {
             }
 
-            public function handlePush(PushRequest $request): PushRequest
+            public function handle(Request $request): Request
             {
                 return $this->dispatcher
                     ->withMiddlewares($this->middlewares)
-                    ->dispatch($request, $this->adapterPushHandler);
+                    ->dispatch($request, $this->adapterHandler);
             }
         };
     }
diff --git a/src/QueueInterface.php b/src/QueueInterface.php
index f8734c9f..835d7a52 100644
--- a/src/QueueInterface.php
+++ b/src/QueueInterface.php
@@ -8,7 +8,7 @@
 use Yiisoft\Queue\Adapter\AdapterInterface;
 use Yiisoft\Queue\Enum\JobStatus;
 use Yiisoft\Queue\Message\MessageInterface;
-use Yiisoft\Queue\Middleware\Push\MiddlewarePushInterface;
+use Yiisoft\Queue\Middleware\MiddlewareInterface;
 
 /**
  * @internal Please don't use this interface. It is only used here to make tests simpler and will be removed
@@ -20,11 +20,11 @@ interface QueueInterface
      * Pushes a message into the queue.
      *
      * @param MessageInterface $message
-     * @param array|callable|MiddlewarePushInterface|string ...$middlewareDefinitions
+     * @param array|callable|MiddlewareInterface|string ...$middlewareDefinitions
      *
      * @return MessageInterface
      */
-    public function push(MessageInterface $message, MiddlewarePushInterface|callable|array|string ...$middlewareDefinitions): MessageInterface;
+    public function push(MessageInterface $message, MiddlewareInterface|callable|array|string ...$middlewareDefinitions): MessageInterface;
 
     /**
      * Execute all existing jobs and exit
@@ -51,6 +51,8 @@ public function status(string|int $id): JobStatus;
 
     public function withAdapter(AdapterInterface $adapter): self;
 
+    public function getAdapter(): ?AdapterInterface;
+
     public function getChannelName(): string;
 
     public function withChannelName(string $channel): self;
diff --git a/src/Worker/Worker.php b/src/Worker/Worker.php
index a42f0c75..16953be2 100644
--- a/src/Worker/Worker.php
+++ b/src/Worker/Worker.php
@@ -4,7 +4,6 @@
 
 namespace Yiisoft\Queue\Worker;
 
-use Closure;
 use Psr\Container\ContainerExceptionInterface;
 use Psr\Container\ContainerInterface;
 use Psr\Container\NotFoundExceptionInterface;
@@ -16,14 +15,12 @@
 use Yiisoft\Injector\Injector;
 use Yiisoft\Queue\Exception\JobFailureException;
 use Yiisoft\Queue\Message\MessageInterface;
-use Yiisoft\Queue\Middleware\Consume\ConsumeFinalHandler;
-use Yiisoft\Queue\Middleware\Consume\ConsumeMiddlewareDispatcher;
-use Yiisoft\Queue\Middleware\Consume\ConsumeRequest;
-use Yiisoft\Queue\Middleware\Consume\MessageHandlerConsumeInterface;
+use Yiisoft\Queue\Middleware\ConsumeFinalHandler;
 use Yiisoft\Queue\Middleware\FailureHandling\FailureFinalHandler;
 use Yiisoft\Queue\Middleware\FailureHandling\FailureHandlingRequest;
 use Yiisoft\Queue\Middleware\FailureHandling\FailureMiddlewareDispatcher;
-use Yiisoft\Queue\Middleware\FailureHandling\MessageFailureHandlerInterface;
+use Yiisoft\Queue\Middleware\MiddlewareDispatcher;
+use Yiisoft\Queue\Middleware\Request;
 use Yiisoft\Queue\QueueInterface;
 use Yiisoft\Queue\Message\IdEnvelope;
 
@@ -36,7 +33,7 @@ public function __construct(
         private LoggerInterface $logger,
         private Injector $injector,
         private ContainerInterface $container,
-        private ConsumeMiddlewareDispatcher $consumeMiddlewareDispatcher,
+        private MiddlewareDispatcher $consumeMiddlewareDispatcher,
         private FailureMiddlewareDispatcher $failureMiddlewareDispatcher,
     ) {
     }
@@ -54,15 +51,15 @@ public function process(MessageInterface $message, QueueInterface $queue): Messa
             throw new RuntimeException("Queue handler with name $name doesn't exist");
         }
 
-        $request = new ConsumeRequest($message, $queue);
+        $request = new Request($message, $queue->getAdapter());
         $closure = fn (MessageInterface $message): mixed => $this->injector->invoke($handler, [$message]);
         try {
-            return $this->consumeMiddlewareDispatcher->dispatch($request, $this->createConsumeHandler($closure))->getMessage();
+            return $this->consumeMiddlewareDispatcher->dispatch($request, new ConsumeFinalHandler($closure))->getMessage();
         } catch (Throwable $exception) {
-            $request = new FailureHandlingRequest($request->getMessage(), $exception, $request->getQueue());
+            $request = new FailureHandlingRequest($request->getMessage(), $exception, $queue);
 
             try {
-                $result = $this->failureMiddlewareDispatcher->dispatch($request, $this->createFailureHandler());
+                $result = $this->failureMiddlewareDispatcher->dispatch($request, new FailureFinalHandler());
                 $this->logger->info($exception->getMessage());
 
                 return $result->getMessage();
@@ -140,14 +137,4 @@ private function prepare(callable|object|array|string|null $definition): callabl
 
         return $definition;
     }
-
-    private function createConsumeHandler(Closure $handler): MessageHandlerConsumeInterface
-    {
-        return new ConsumeFinalHandler($handler);
-    }
-
-    private function createFailureHandler(): MessageFailureHandlerInterface
-    {
-        return new FailureFinalHandler();
-    }
 }
diff --git a/tests/App/DummyQueue.php b/tests/App/DummyQueue.php
index 42125909..d40f27ae 100644
--- a/tests/App/DummyQueue.php
+++ b/tests/App/DummyQueue.php
@@ -8,7 +8,7 @@
 use Yiisoft\Queue\Adapter\AdapterInterface;
 use Yiisoft\Queue\Enum\JobStatus;
 use Yiisoft\Queue\Message\MessageInterface;
-use Yiisoft\Queue\Middleware\Push\MiddlewarePushInterface;
+use Yiisoft\Queue\Middleware\MiddlewareInterface;
 use Yiisoft\Queue\QueueInterface;
 
 final class DummyQueue implements QueueInterface
@@ -19,7 +19,7 @@ public function __construct(private string $channelName)
 
     public function push(
         MessageInterface $message,
-        string|array|callable|MiddlewarePushInterface ...$middlewareDefinitions
+        string|array|callable|MiddlewareInterface ...$middlewareDefinitions
     ): MessageInterface {
         return $message;
     }
@@ -52,4 +52,9 @@ public function withChannelName(string $channel): QueueInterface
     {
         throw new Exception('`withChannelName()` method is not implemented yet.');
     }
+
+    public function getAdapter(): ?AdapterInterface
+    {
+        return null;
+    }
 }
diff --git a/tests/Integration/MessageConsumingTest.php b/tests/Integration/MessageConsumingTest.php
index 6c30ba92..70ef607a 100644
--- a/tests/Integration/MessageConsumingTest.php
+++ b/tests/Integration/MessageConsumingTest.php
@@ -9,10 +9,10 @@
 use Yiisoft\Injector\Injector;
 use Yiisoft\Queue\Message\Message;
 use Yiisoft\Queue\Message\MessageInterface;
-use Yiisoft\Queue\Middleware\Consume\ConsumeMiddlewareDispatcher;
-use Yiisoft\Queue\Middleware\Consume\MiddlewareFactoryConsumeInterface;
 use Yiisoft\Queue\Middleware\FailureHandling\FailureMiddlewareDispatcher;
 use Yiisoft\Queue\Middleware\FailureHandling\MiddlewareFactoryFailureInterface;
+use Yiisoft\Queue\Middleware\MiddlewareDispatcher;
+use Yiisoft\Queue\Middleware\MiddlewareFactoryInterface;
 use Yiisoft\Queue\Tests\TestCase;
 use Yiisoft\Queue\Worker\Worker;
 
@@ -30,7 +30,7 @@ public function testMessagesConsumed(): void
             new NullLogger(),
             new Injector($container),
             $container,
-            new ConsumeMiddlewareDispatcher($this->createMock(MiddlewareFactoryConsumeInterface::class)),
+            new MiddlewareDispatcher($this->createMock(MiddlewareFactoryInterface::class)),
             new FailureMiddlewareDispatcher($this->createMock(MiddlewareFactoryFailureInterface::class), [])
         );
 
diff --git a/tests/Integration/MiddlewareTest.php b/tests/Integration/MiddlewareTest.php
index ed8f6ad3..8aae0436 100644
--- a/tests/Integration/MiddlewareTest.php
+++ b/tests/Integration/MiddlewareTest.php
@@ -9,6 +9,7 @@
 use Psr\Container\ContainerInterface;
 use Psr\Log\LoggerInterface;
 use Yiisoft\Injector\Injector;
+use Yiisoft\Queue\Middleware\DelayMiddlewareInterface;
 use Yiisoft\Test\Support\Container\SimpleContainer;
 use Yiisoft\Test\Support\Log\SimpleLogger;
 use Yiisoft\Queue\Adapter\SynchronousAdapter;
@@ -16,17 +17,14 @@
 use Yiisoft\Queue\Message\Message;
 use Yiisoft\Queue\Message\MessageInterface;
 use Yiisoft\Queue\Middleware\CallableFactory;
-use Yiisoft\Queue\Middleware\Consume\ConsumeMiddlewareDispatcher;
-use Yiisoft\Queue\Middleware\Consume\MiddlewareFactoryConsume;
+use Yiisoft\Queue\Middleware\MiddlewareDispatcher;
 use Yiisoft\Queue\Middleware\FailureHandling\FailureFinalHandler;
 use Yiisoft\Queue\Middleware\FailureHandling\FailureHandlingRequest;
 use Yiisoft\Queue\Middleware\FailureHandling\FailureMiddlewareDispatcher;
 use Yiisoft\Queue\Middleware\FailureHandling\Implementation\ExponentialDelayMiddleware;
 use Yiisoft\Queue\Middleware\FailureHandling\Implementation\SendAgainMiddleware;
 use Yiisoft\Queue\Middleware\FailureHandling\MiddlewareFactoryFailure;
-use Yiisoft\Queue\Middleware\Push\Implementation\DelayMiddlewareInterface;
-use Yiisoft\Queue\Middleware\Push\MiddlewareFactoryPush;
-use Yiisoft\Queue\Middleware\Push\PushMiddlewareDispatcher;
+use Yiisoft\Queue\Middleware\MiddlewareFactory;
 use Yiisoft\Queue\Queue;
 use Yiisoft\Queue\QueueInterface;
 use Yiisoft\Queue\Tests\Integration\Support\TestMiddleware;
@@ -48,8 +46,8 @@ public function testFullStackPush(): void
             'message 2',
         ];
 
-        $pushMiddlewareDispatcher = new PushMiddlewareDispatcher(
-            new MiddlewareFactoryPush(
+        $pushMiddlewareDispatcher = new MiddlewareDispatcher(
+            new MiddlewareFactory(
                 $this->createMock(ContainerInterface::class),
                 new CallableFactory(
                     $this->createMock(ContainerInterface::class)
@@ -93,8 +91,8 @@ public function testFullStackConsume(): void
         $container = new SimpleContainer();
         $callableFactory = new CallableFactory($container);
 
-        $consumeMiddlewareDispatcher = new ConsumeMiddlewareDispatcher(
-            new MiddlewareFactoryConsume(
+        $consumeMiddlewareDispatcher = new MiddlewareDispatcher(
+            new MiddlewareFactory(
                 $this->createMock(ContainerInterface::class),
                 new CallableFactory(
                     $this->createMock(ContainerInterface::class)
diff --git a/tests/Integration/QueueFactoryTest.php b/tests/Integration/QueueFactoryTest.php
index 50076896..0a3dc936 100644
--- a/tests/Integration/QueueFactoryTest.php
+++ b/tests/Integration/QueueFactoryTest.php
@@ -11,8 +11,8 @@
 use Yiisoft\Queue\Adapter\SynchronousAdapter;
 use Yiisoft\Queue\Cli\LoopInterface;
 use Yiisoft\Queue\Middleware\CallableFactory;
-use Yiisoft\Queue\Middleware\Push\MiddlewareFactoryPushInterface;
-use Yiisoft\Queue\Middleware\Push\PushMiddlewareDispatcher;
+use Yiisoft\Queue\Middleware\MiddlewareFactoryInterface;
+use Yiisoft\Queue\Middleware\MiddlewareDispatcher;
 use Yiisoft\Queue\Queue;
 use Yiisoft\Queue\QueueFactory;
 use Yiisoft\Queue\QueueFactoryInterface;
@@ -76,7 +76,7 @@ private function getDefaultQueue(WorkerInterface $worker): Queue
             $worker,
             $this->createMock(LoopInterface::class),
             $this->createMock(LoggerInterface::class),
-            new PushMiddlewareDispatcher($this->createMock(MiddlewareFactoryPushInterface::class)),
+            new MiddlewareDispatcher($this->createMock(MiddlewareFactoryInterface::class)),
         );
     }
 }
diff --git a/tests/Integration/Support/ConsumeMiddleware.php b/tests/Integration/Support/ConsumeMiddleware.php
new file mode 100644
index 00000000..347920f4
--- /dev/null
+++ b/tests/Integration/Support/ConsumeMiddleware.php
@@ -0,0 +1,27 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Yiisoft\Queue\Tests\Integration\Support;
+
+use Yiisoft\Queue\Message\Message;
+use Yiisoft\Queue\Middleware\MessageHandlerInterface;
+use Yiisoft\Queue\Middleware\MiddlewareInterface;
+use Yiisoft\Queue\Middleware\Request;
+
+final class ConsumeMiddleware implements MiddlewareInterface
+{
+    public function __construct(private string $stage)
+    {
+    }
+
+    public function process(Request $request, MessageHandlerInterface $handler): Request
+    {
+        $message = $request->getMessage();
+        $stack = $message->getData();
+        $stack[] = $this->stage;
+        $messageNew = new Message($message->getHandlerName(), $stack);
+
+        return $handler->handle($request->withMessage($messageNew));
+    }
+}
diff --git a/tests/Integration/Support/TestMiddleware.php b/tests/Integration/Support/TestMiddleware.php
index 54ea46bb..8662b4bb 100644
--- a/tests/Integration/Support/TestMiddleware.php
+++ b/tests/Integration/Support/TestMiddleware.php
@@ -5,36 +5,33 @@
 namespace Yiisoft\Queue\Tests\Integration\Support;
 
 use Yiisoft\Queue\Message\Message;
-use Yiisoft\Queue\Middleware\Consume\ConsumeRequest;
-use Yiisoft\Queue\Middleware\Consume\MessageHandlerConsumeInterface;
-use Yiisoft\Queue\Middleware\Consume\MiddlewareConsumeInterface;
-use Yiisoft\Queue\Middleware\Push\MessageHandlerPushInterface;
-use Yiisoft\Queue\Middleware\Push\MiddlewarePushInterface;
-use Yiisoft\Queue\Middleware\Push\PushRequest;
-
-final class TestMiddleware implements MiddlewarePushInterface, MiddlewareConsumeInterface
+use Yiisoft\Queue\Middleware\MessageHandlerInterface;
+use Yiisoft\Queue\Middleware\MiddlewareInterface;
+use Yiisoft\Queue\Middleware\Request;
+
+final class TestMiddleware implements MiddlewareInterface
 {
     public function __construct(private string $stage)
     {
     }
 
-    public function processPush(PushRequest $request, MessageHandlerPushInterface $handler): PushRequest
+    public function process(Request $request, MessageHandlerInterface $handler): Request
     {
         $message = $request->getMessage();
         $stack = $message->getData();
         $stack[] = $this->stage;
         $messageNew = new Message($message->getHandlerName(), $stack);
 
-        return $handler->handlePush($request->withMessage($messageNew));
+        return $handler->handle($request->withMessage($messageNew));
     }
 
-    public function processConsume(ConsumeRequest $request, MessageHandlerConsumeInterface $handler): ConsumeRequest
+    public function process2(Request $request, MessageHandlerInterface $handler): Request
     {
         $message = $request->getMessage();
         $stack = $message->getData();
         $stack[] = $this->stage;
         $messageNew = new Message($message->getHandlerName(), $stack);
 
-        return $handler->handleConsume($request->withMessage($messageNew));
+        return $handler->handle($request->withMessage($messageNew));
     }
 }
diff --git a/tests/TestCase.php b/tests/TestCase.php
index 8f64bd8c..37b13e37 100644
--- a/tests/TestCase.php
+++ b/tests/TestCase.php
@@ -10,18 +10,16 @@
 use Psr\Log\NullLogger;
 use RuntimeException;
 use Yiisoft\Injector\Injector;
+use Yiisoft\Queue\Middleware\MiddlewareDispatcher;
 use Yiisoft\Test\Support\Container\SimpleContainer;
 use Yiisoft\Queue\Adapter\AdapterInterface;
 use Yiisoft\Queue\Adapter\SynchronousAdapter;
 use Yiisoft\Queue\Cli\LoopInterface;
 use Yiisoft\Queue\Cli\SimpleLoop;
 use Yiisoft\Queue\Middleware\CallableFactory;
-use Yiisoft\Queue\Middleware\Consume\ConsumeMiddlewareDispatcher;
-use Yiisoft\Queue\Middleware\Consume\MiddlewareFactoryConsume;
+use Yiisoft\Queue\Middleware\MiddlewareFactory;
 use Yiisoft\Queue\Middleware\FailureHandling\FailureMiddlewareDispatcher;
 use Yiisoft\Queue\Middleware\FailureHandling\MiddlewareFactoryFailure;
-use Yiisoft\Queue\Middleware\Push\MiddlewareFactoryPush;
-use Yiisoft\Queue\Middleware\Push\PushMiddlewareDispatcher;
 use Yiisoft\Queue\Queue;
 use Yiisoft\Queue\Worker\Worker;
 use Yiisoft\Queue\Worker\WorkerInterface;
@@ -109,7 +107,7 @@ protected function createQueue(): Queue
             $this->getWorker(),
             $this->getLoop(),
             new NullLogger(),
-            $this->getPushMiddlewareDispatcher(),
+            $this->getMiddlewareDispatcher(),
         );
     }
 
@@ -134,7 +132,7 @@ protected function createWorker(): WorkerInterface
             new NullLogger(),
             new Injector($this->getContainer()),
             $this->getContainer(),
-            $this->getConsumeMiddlewareDispatcher(),
+            $this->getMiddlewareDispatcher(),
             $this->getFailureMiddlewareDispatcher(),
         );
     }
@@ -181,20 +179,10 @@ protected function needsRealAdapter(): bool
         return false;
     }
 
-    protected function getPushMiddlewareDispatcher(): PushMiddlewareDispatcher
+    protected function getMiddlewareDispatcher(): MiddlewareDispatcher
     {
-        return new PushMiddlewareDispatcher(
-            new MiddlewareFactoryPush(
-                $this->getContainer(),
-                new CallableFactory($this->getContainer()),
-            ),
-        );
-    }
-
-    protected function getConsumeMiddlewareDispatcher(): ConsumeMiddlewareDispatcher
-    {
-        return new ConsumeMiddlewareDispatcher(
-            new MiddlewareFactoryConsume(
+        return new MiddlewareDispatcher(
+            new MiddlewareFactory(
                 $this->getContainer(),
                 new CallableFactory($this->getContainer()),
             ),
diff --git a/tests/Unit/Middleware/Consume/ConsumeRequestTest.php b/tests/Unit/Middleware/Consume/ConsumeRequestTest.php
index 6493fccd..053e7668 100644
--- a/tests/Unit/Middleware/Consume/ConsumeRequestTest.php
+++ b/tests/Unit/Middleware/Consume/ConsumeRequestTest.php
@@ -4,9 +4,9 @@
 
 namespace Yiisoft\Queue\Tests\Unit\Middleware\Consume;
 
+use Yiisoft\Queue\Adapter\AdapterInterface;
 use Yiisoft\Queue\Message\Message;
-use Yiisoft\Queue\Middleware\Consume\ConsumeRequest;
-use Yiisoft\Queue\QueueInterface;
+use Yiisoft\Queue\Middleware\Request;
 use Yiisoft\Queue\Tests\TestCase;
 
 final class ConsumeRequestTest extends TestCase
@@ -14,10 +14,10 @@ final class ConsumeRequestTest extends TestCase
     public function testImmutable(): void
     {
         $message = new Message('test', 'test');
-        $queue = $this->createMock(QueueInterface::class);
-        $consumeRequest = new ConsumeRequest($message, $queue);
+        $adapter = $this->createMock(AdapterInterface::class);
+        $consumeRequest = new Request($message, $adapter);
 
         $this->assertNotSame($consumeRequest, $consumeRequest->withMessage($message));
-        $this->assertNotSame($consumeRequest, $consumeRequest->withQueue($queue));
+        $this->assertNotSame($consumeRequest, $consumeRequest->withAdapter($adapter));
     }
 }
diff --git a/tests/Unit/Middleware/Consume/InvalidMiddlewareDefinitionExceptionTest.php b/tests/Unit/Middleware/Consume/InvalidMiddlewareDefinitionExceptionTest.php
index 756c616d..d0cb45cb 100644
--- a/tests/Unit/Middleware/Consume/InvalidMiddlewareDefinitionExceptionTest.php
+++ b/tests/Unit/Middleware/Consume/InvalidMiddlewareDefinitionExceptionTest.php
@@ -8,7 +8,7 @@
 use PHPUnit\Framework\TestCase;
 use stdClass;
 use Yiisoft\Queue\Middleware\InvalidMiddlewareDefinitionException;
-use Yiisoft\Queue\Tests\Unit\Middleware\Consume\Support\TestCallableMiddleware;
+use Yiisoft\Queue\Tests\Unit\Middleware\Support\TestCallableMiddleware;
 
 final class InvalidMiddlewareDefinitionExceptionTest extends TestCase
 {
@@ -21,15 +21,24 @@ public static function dataBase(): array
             ],
             [
                 new TestCallableMiddleware(),
-                'an instance of "Yiisoft\Queue\Tests\Unit\Middleware\Consume\Support\TestCallableMiddleware"',
+                sprintf(
+                    'an instance of "%s"',
+                    TestCallableMiddleware::class,
+                ),
             ],
             [
                 [TestCallableMiddleware::class, 'notExistsAction'],
-                '["Yiisoft\Queue\Tests\Unit\Middleware\Consume\Support\TestCallableMiddleware", "notExistsAction"]',
+                sprintf(
+                    '["%s", "notExistsAction"]',
+                    TestCallableMiddleware::class,
+                ),
             ],
             [
                 ['class' => TestCallableMiddleware::class, 'index'],
-                '["class" => "Yiisoft\Queue\Tests\Unit\Middleware\Consume\Support\TestCallableMiddleware", "index"]',
+                sprintf(
+                    '["class" => "%s", "index"]',
+                    TestCallableMiddleware::class,
+                ),
             ],
         ];
     }
diff --git a/tests/Unit/Middleware/Consume/MiddlewareDispatcherTest.php b/tests/Unit/Middleware/Consume/MiddlewareDispatcherTest.php
index 15d1356c..e4c9bbdb 100644
--- a/tests/Unit/Middleware/Consume/MiddlewareDispatcherTest.php
+++ b/tests/Unit/Middleware/Consume/MiddlewareDispatcherTest.php
@@ -7,30 +7,31 @@
 use PHPUnit\Framework\Attributes\DataProvider;
 use PHPUnit\Framework\TestCase;
 use Psr\Container\ContainerInterface;
+use Yiisoft\Queue\Tests\Unit\Middleware\Support\TestCallableMiddleware;
+use Yiisoft\Queue\Tests\Unit\Middleware\Support\TestMiddleware;
 use Yiisoft\Test\Support\Container\SimpleContainer;
 use Yiisoft\Queue\Adapter\AdapterInterface;
 use Yiisoft\Queue\Message\Message;
 use Yiisoft\Queue\Middleware\CallableFactory;
-use Yiisoft\Queue\Middleware\Consume\ConsumeMiddlewareDispatcher;
-use Yiisoft\Queue\Middleware\Consume\ConsumeRequest;
-use Yiisoft\Queue\Middleware\Consume\MessageHandlerConsumeInterface;
-use Yiisoft\Queue\Middleware\Consume\MiddlewareFactoryConsume;
+use Yiisoft\Queue\Middleware\MiddlewareDispatcher;
+use Yiisoft\Queue\Middleware\Request;
+use Yiisoft\Queue\Middleware\MessageHandlerInterface;
+use Yiisoft\Queue\Middleware\MiddlewareFactory;
 use Yiisoft\Queue\QueueInterface;
 use Yiisoft\Queue\Tests\App\FakeAdapter;
-use Yiisoft\Queue\Tests\Unit\Middleware\Consume\Support\TestCallableMiddleware;
-use Yiisoft\Queue\Tests\Unit\Middleware\Consume\Support\TestMiddleware;
 
 final class MiddlewareDispatcherTest extends TestCase
 {
     public function testCallableMiddlewareCalled(): void
     {
-        $request = $this->getConsumeRequest();
+        $request = $this->getRequest();
         $queue = $this->createMock(QueueInterface::class);
+        $adapter = $this->createMock(AdapterInterface::class);
 
         $dispatcher = $this->createDispatcher()->withMiddlewares(
             [
-                static function (ConsumeRequest $request) use ($queue): ConsumeRequest {
-                    return $request->withMessage(new Message('test', 'New closure test data'))->withQueue($queue);
+                static function (Request $request) use ($adapter): Request {
+                    return $request->withMessage(new Message('test', 'New closure test data'))->withAdapter($adapter);
                 },
             ]
         );
@@ -41,7 +42,7 @@ static function (ConsumeRequest $request) use ($queue): ConsumeRequest {
 
     public function testArrayMiddlewareCallableDefinition(): void
     {
-        $request = $this->getConsumeRequest();
+        $request = $this->getRequest();
         $container = $this->createContainer(
             [
                 TestCallableMiddleware::class => new TestCallableMiddleware(),
@@ -54,7 +55,7 @@ public function testArrayMiddlewareCallableDefinition(): void
 
     public function testFactoryArrayDefinition(): void
     {
-        $request = $this->getConsumeRequest();
+        $request = $this->getRequest();
         $container = $this->createContainer();
         $definition = [
             'class' => TestMiddleware::class,
@@ -67,17 +68,17 @@ public function testFactoryArrayDefinition(): void
 
     public function testMiddlewareFullStackCalled(): void
     {
-        $request = $this->getConsumeRequest();
+        $request = $this->getRequest();
 
-        $middleware1 = static function (ConsumeRequest $request, MessageHandlerConsumeInterface $handler): ConsumeRequest {
+        $middleware1 = static function (Request $request, MessageHandlerInterface $handler): Request {
             $request = $request->withMessage(new Message($request->getMessage()->getHandlerName(), 'new test data'));
 
-            return $handler->handleConsume($request);
+            return $handler->handle($request);
         };
-        $middleware2 = static function (ConsumeRequest $request, MessageHandlerConsumeInterface $handler): ConsumeRequest {
+        $middleware2 = static function (Request $request, MessageHandlerInterface $handler): Request {
             $request = $request->withMessage(new Message('new handler', $request->getMessage()->getData()));
 
-            return $handler->handleConsume($request);
+            return $handler->handle($request);
         };
 
         $dispatcher = $this->createDispatcher()->withMiddlewares([$middleware1, $middleware2]);
@@ -89,12 +90,12 @@ public function testMiddlewareFullStackCalled(): void
 
     public function testMiddlewareStackInterrupted(): void
     {
-        $request = $this->getConsumeRequest();
+        $request = $this->getRequest();
 
-        $middleware1 = static function (ConsumeRequest $request, MessageHandlerConsumeInterface $handler): ConsumeRequest {
+        $middleware1 = static function (Request $request, MessageHandlerInterface $handler): Request {
             return $request->withMessage(new Message($request->getMessage()->getHandlerName(), 'first'));
         };
-        $middleware2 = static function (ConsumeRequest $request, MessageHandlerConsumeInterface $handler): ConsumeRequest {
+        $middleware2 = static function (Request $request, MessageHandlerInterface $handler): Request {
             return $request->withMessage(new Message($request->getMessage()->getHandlerName(), 'second'));
         };
 
@@ -129,7 +130,7 @@ public function testImmutability(): void
 
     public function testResetStackOnWithMiddlewares(): void
     {
-        $request = $this->getConsumeRequest();
+        $request = $this->getRequest();
         $container = $this->createContainer(
             [
                 TestCallableMiddleware::class => new TestCallableMiddleware(),
@@ -148,10 +149,10 @@ public function testResetStackOnWithMiddlewares(): void
         self::assertSame('New middleware test data', $request->getMessage()->getData());
     }
 
-    private function getRequestHandler(): MessageHandlerConsumeInterface
+    private function getRequestHandler(): MessageHandlerInterface
     {
-        return new class () implements MessageHandlerConsumeInterface {
-            public function handleConsume(ConsumeRequest $request): ConsumeRequest
+        return new class () implements MessageHandlerInterface {
+            public function handle(Request $request): Request
             {
                 return $request;
             }
@@ -160,12 +161,12 @@ public function handleConsume(ConsumeRequest $request): ConsumeRequest
 
     private function createDispatcher(
         ContainerInterface $container = null,
-    ): ConsumeMiddlewareDispatcher {
+    ): MiddlewareDispatcher {
         $container ??= $this->createContainer([AdapterInterface::class => new FakeAdapter()]);
         $callableFactory = new CallableFactory($container);
 
-        return new ConsumeMiddlewareDispatcher(
-            new MiddlewareFactoryConsume($container, $callableFactory),
+        return new MiddlewareDispatcher(
+            new MiddlewareFactory($container, $callableFactory),
         );
     }
 
@@ -174,11 +175,11 @@ private function createContainer(array $instances = []): ContainerInterface
         return new SimpleContainer($instances);
     }
 
-    private function getConsumeRequest(): ConsumeRequest
+    private function getRequest(): Request
     {
-        return new ConsumeRequest(
+        return new Request(
             new Message('handler', 'data'),
-            $this->createMock(QueueInterface::class)
+            $this->createMock(AdapterInterface::class)
         );
     }
 }
diff --git a/tests/Unit/Middleware/Consume/MiddlewareFactoryTest.php b/tests/Unit/Middleware/Consume/MiddlewareFactoryTest.php
index d61919cb..1d95d3d2 100644
--- a/tests/Unit/Middleware/Consume/MiddlewareFactoryTest.php
+++ b/tests/Unit/Middleware/Consume/MiddlewareFactoryTest.php
@@ -7,49 +7,48 @@
 use PHPUnit\Framework\Attributes\DataProvider;
 use PHPUnit\Framework\TestCase;
 use Psr\Container\ContainerInterface;
+use Yiisoft\Queue\Tests\Integration\Support\ConsumeMiddleware;
+use Yiisoft\Queue\Tests\Unit\Middleware\Support\TestCallableMiddleware;
 use Yiisoft\Test\Support\Container\SimpleContainer;
 use Yiisoft\Queue\Adapter\AdapterInterface;
 use Yiisoft\Queue\Message\Message;
 use Yiisoft\Queue\Middleware\CallableFactory;
-use Yiisoft\Queue\Middleware\Consume\ConsumeRequest;
-use Yiisoft\Queue\Middleware\Consume\MessageHandlerConsumeInterface;
-use Yiisoft\Queue\Middleware\Consume\MiddlewareConsumeInterface;
-use Yiisoft\Queue\Middleware\Consume\MiddlewareFactoryConsume;
-use Yiisoft\Queue\Middleware\Consume\MiddlewareFactoryConsumeInterface;
+use Yiisoft\Queue\Middleware\Request;
+use Yiisoft\Queue\Middleware\MessageHandlerInterface;
+use Yiisoft\Queue\Middleware\MiddlewareInterface;
+use Yiisoft\Queue\Middleware\MiddlewareFactory;
+use Yiisoft\Queue\Middleware\MiddlewareFactoryInterface;
 use Yiisoft\Queue\Middleware\InvalidMiddlewareDefinitionException;
-use Yiisoft\Queue\QueueInterface;
 use Yiisoft\Queue\Tests\App\FakeAdapter;
-use Yiisoft\Queue\Tests\Unit\Middleware\Consume\Support\InvalidController;
-use Yiisoft\Queue\Tests\Unit\Middleware\Consume\Support\TestCallableMiddleware;
-use Yiisoft\Queue\Tests\Unit\Middleware\Consume\Support\TestMiddleware;
+use Yiisoft\Queue\Tests\Unit\Middleware\Support\InvalidController;
 
 final class MiddlewareFactoryTest extends TestCase
 {
     public function testCreateFromClassString(): void
     {
-        $container = $this->getContainer([TestMiddleware::class => new TestMiddleware()]);
-        $middleware = $this->getMiddlewareFactory($container)->createConsumeMiddleware(TestMiddleware::class);
-        self::assertInstanceOf(TestMiddleware::class, $middleware);
+        $container = $this->getContainer([ConsumeMiddleware::class => new ConsumeMiddleware('stage1')]);
+        $middleware = $this->getMiddlewareFactory($container)->createMiddleware(ConsumeMiddleware::class);
+        self::assertInstanceOf(ConsumeMiddleware::class, $middleware);
     }
 
     public function testCreateFromAliasString(): void
     {
-        $container = $this->getContainer(['test' => new TestMiddleware()]);
-        $middleware = $this->getMiddlewareFactory($container)->createConsumeMiddleware('test');
-        self::assertInstanceOf(TestMiddleware::class, $middleware);
+        $container = $this->getContainer(['test' => new ConsumeMiddleware('stage1')]);
+        $middleware = $this->getMiddlewareFactory($container)->createMiddleware('test');
+        self::assertInstanceOf(ConsumeMiddleware::class, $middleware);
     }
 
     public function testCreateFromArray(): void
     {
         $container = $this->getContainer([TestCallableMiddleware::class => new TestCallableMiddleware()]);
-        $middleware = $this->getMiddlewareFactory($container)->createConsumeMiddleware(
+        $middleware = $this->getMiddlewareFactory($container)->createMiddleware(
             [TestCallableMiddleware::class, 'index']
         );
         self::assertSame(
             'New test data',
-            $middleware->processConsume(
-                $this->getConsumeRequest(),
-                $this->createMock(MessageHandlerConsumeInterface::class)
+            $middleware->process(
+                $this->getRequest(),
+                $this->createMock(MessageHandlerInterface::class)
             )->getMessage()->getData(),
         );
     }
@@ -57,17 +56,17 @@ public function testCreateFromArray(): void
     public function testCreateFromClosureResponse(): void
     {
         $container = $this->getContainer([TestCallableMiddleware::class => new TestCallableMiddleware()]);
-        $middleware = $this->getMiddlewareFactory($container)->createConsumeMiddleware(
-            fn (): ConsumeRequest => new ConsumeRequest(
+        $middleware = $this->getMiddlewareFactory($container)->createMiddleware(
+            fn (): Request => new Request(
                 new Message('test', 'test data'),
-                $this->createMock(QueueInterface::class),
+                $this->createMock(AdapterInterface::class),
             )
         );
         self::assertSame(
             'test data',
-            $middleware->processConsume(
-                $this->getConsumeRequest(),
-                $this->createMock(MessageHandlerConsumeInterface::class)
+            $middleware->process(
+                $this->getRequest(),
+                $this->createMock(MessageHandlerInterface::class)
             )->getMessage()->getData()
         );
     }
@@ -75,27 +74,35 @@ public function testCreateFromClosureResponse(): void
     public function testCreateFromClosureMiddleware(): void
     {
         $container = $this->getContainer([TestCallableMiddleware::class => new TestCallableMiddleware()]);
-        $middleware = $this->getMiddlewareFactory($container)->createConsumeMiddleware(
-            static fn (): MiddlewareConsumeInterface => new TestMiddleware()
+        $middleware = $this->getMiddlewareFactory($container)->createMiddleware(
+            static fn (): MiddlewareInterface => new ConsumeMiddleware('stage1')
         );
+
+        $handler = $this->createMock(MessageHandlerInterface::class);
+        $handler->expects($this->once())->method('handle')->willReturnCallback(
+            static fn (Request $request): Request => $request->withMessage(
+                new Message('test', 'New middleware test data')
+            )
+        );
+
         self::assertSame(
             'New middleware test data',
-            $middleware->processConsume(
-                $this->getConsumeRequest(),
-                $this->createMock(MessageHandlerConsumeInterface::class)
+            $middleware->process(
+                $this->getRequest(),
+                $handler
             )->getMessage()->getData()
         );
     }
 
     public function testCreateWithUseParamsMiddleware(): void
     {
-        $container = $this->getContainer([TestMiddleware::class => new TestMiddleware()]);
-        $middleware = $this->getMiddlewareFactory($container)->createConsumeMiddleware(TestMiddleware::class);
+        $container = $this->getContainer([ConsumeMiddleware::class => new ConsumeMiddleware('stage1')]);
+        $middleware = $this->getMiddlewareFactory($container)->createMiddleware(ConsumeMiddleware::class);
 
         self::assertSame(
-            'New middleware test data',
-            $middleware->processConsume(
-                $this->getConsumeRequest(),
+            ['data', 'stage1'],
+            $middleware->process(
+                $this->getRequest(),
                 $this->getRequestHandler()
             )->getMessage()->getData()
         );
@@ -104,14 +111,14 @@ public function testCreateWithUseParamsMiddleware(): void
     public function testCreateWithTestCallableMiddleware(): void
     {
         $container = $this->getContainer([TestCallableMiddleware::class => new TestCallableMiddleware()]);
-        $middleware = $this->getMiddlewareFactory($container)->createConsumeMiddleware(
+        $middleware = $this->getMiddlewareFactory($container)->createMiddleware(
             [TestCallableMiddleware::class, 'index']
         );
-        $request = $this->getConsumeRequest();
+        $request = $this->getRequest();
 
         self::assertSame(
             'New test data',
-            $middleware->processConsume(
+            $middleware->process(
                 $request,
                 $this->getRequestHandler()
             )->getMessage()->getData()
@@ -121,14 +128,14 @@ public function testCreateWithTestCallableMiddleware(): void
     public function testInvalidMiddlewareWithWrongCallable(): void
     {
         $container = $this->getContainer([TestCallableMiddleware::class => new TestCallableMiddleware()]);
-        $middleware = $this->getMiddlewareFactory($container)->createConsumeMiddleware(
+        $middleware = $this->getMiddlewareFactory($container)->createMiddleware(
             static fn () => 42
         );
 
         $this->expectException(InvalidMiddlewareDefinitionException::class);
-        $middleware->processConsume(
-            $this->getConsumeRequest(),
-            $this->createMock(MessageHandlerConsumeInterface::class)
+        $middleware->process(
+            $this->getRequest(),
+            $this->createMock(MessageHandlerInterface::class)
         );
     }
 
@@ -150,28 +157,28 @@ public static function invalidMiddlewareDefinitionProvider(): array
     public function testInvalidMiddleware(mixed $definition): void
     {
         $this->expectException(InvalidMiddlewareDefinitionException::class);
-        $this->getMiddlewareFactory()->createConsumeMiddleware($definition);
+        $this->getMiddlewareFactory()->createMiddleware($definition);
     }
 
     public function testInvalidMiddlewareWithWrongController(): void
     {
         $container = $this->getContainer([InvalidController::class => new InvalidController()]);
-        $middleware = $this->getMiddlewareFactory($container)->createConsumeMiddleware(
+        $middleware = $this->getMiddlewareFactory($container)->createMiddleware(
             [InvalidController::class, 'index']
         );
 
         $this->expectException(InvalidMiddlewareDefinitionException::class);
-        $middleware->processConsume(
-            $this->getConsumeRequest(),
-            $this->createMock(MessageHandlerConsumeInterface::class)
+        $middleware->process(
+            $this->getRequest(),
+            $this->createMock(MessageHandlerInterface::class)
         );
     }
 
-    private function getMiddlewareFactory(ContainerInterface $container = null): MiddlewareFactoryConsumeInterface
+    private function getMiddlewareFactory(ContainerInterface $container = null): MiddlewareFactoryInterface
     {
         $container ??= $this->getContainer([AdapterInterface::class => new FakeAdapter()]);
 
-        return new MiddlewareFactoryConsume($container, new CallableFactory($container));
+        return new MiddlewareFactory($container, new CallableFactory($container));
     }
 
     private function getContainer(array $instances = []): ContainerInterface
@@ -179,21 +186,21 @@ private function getContainer(array $instances = []): ContainerInterface
         return new SimpleContainer($instances);
     }
 
-    private function getRequestHandler(): MessageHandlerConsumeInterface
+    private function getRequestHandler(): MessageHandlerInterface
     {
-        return new class () implements MessageHandlerConsumeInterface {
-            public function handleConsume(ConsumeRequest $request): ConsumeRequest
+        return new class () implements MessageHandlerInterface {
+            public function handle(Request $request): Request
             {
                 return $request;
             }
         };
     }
 
-    private function getConsumeRequest(): ConsumeRequest
+    private function getRequest(): Request
     {
-        return new ConsumeRequest(
-            new Message('handler', 'data'),
-            $this->createMock(QueueInterface::class)
+        return new Request(
+            new Message('handler', ['data']),
+            $this->createMock(AdapterInterface::class)
         );
     }
 }
diff --git a/tests/Unit/Middleware/Consume/Support/FailMiddleware.php b/tests/Unit/Middleware/Consume/Support/FailMiddleware.php
deleted file mode 100644
index dd8ed5b7..00000000
--- a/tests/Unit/Middleware/Consume/Support/FailMiddleware.php
+++ /dev/null
@@ -1,18 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Yiisoft\Queue\Tests\Unit\Middleware\Consume\Support;
-
-use RuntimeException;
-use Yiisoft\Queue\Middleware\Consume\MessageHandlerConsumeInterface;
-use Yiisoft\Queue\Middleware\Consume\MiddlewareConsumeInterface;
-use Yiisoft\Queue\Middleware\Consume\ConsumeRequest;
-
-final class FailMiddleware implements MiddlewareConsumeInterface
-{
-    public function processConsume(ConsumeRequest $request, MessageHandlerConsumeInterface $handler): ConsumeRequest
-    {
-        throw new RuntimeException('Middleware failed.');
-    }
-}
diff --git a/tests/Unit/Middleware/Consume/Support/InvalidController.php b/tests/Unit/Middleware/Consume/Support/InvalidController.php
deleted file mode 100644
index 9c7df8d4..00000000
--- a/tests/Unit/Middleware/Consume/Support/InvalidController.php
+++ /dev/null
@@ -1,13 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Yiisoft\Queue\Tests\Unit\Middleware\Consume\Support;
-
-final class InvalidController
-{
-    public function index(): int
-    {
-        return 200;
-    }
-}
diff --git a/tests/Unit/Middleware/Consume/Support/TestCallableMiddleware.php b/tests/Unit/Middleware/Consume/Support/TestCallableMiddleware.php
deleted file mode 100644
index 27b356e2..00000000
--- a/tests/Unit/Middleware/Consume/Support/TestCallableMiddleware.php
+++ /dev/null
@@ -1,16 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Yiisoft\Queue\Tests\Unit\Middleware\Consume\Support;
-
-use Yiisoft\Queue\Message\Message;
-use Yiisoft\Queue\Middleware\Consume\ConsumeRequest;
-
-final class TestCallableMiddleware
-{
-    public function index(ConsumeRequest $request): ConsumeRequest
-    {
-        return $request->withMessage(new Message('test', 'New test data'));
-    }
-}
diff --git a/tests/Unit/Middleware/Consume/Support/TestMiddleware.php b/tests/Unit/Middleware/Consume/Support/TestMiddleware.php
deleted file mode 100644
index 1e4508f0..00000000
--- a/tests/Unit/Middleware/Consume/Support/TestMiddleware.php
+++ /dev/null
@@ -1,22 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Yiisoft\Queue\Tests\Unit\Middleware\Consume\Support;
-
-use Yiisoft\Queue\Message\Message;
-use Yiisoft\Queue\Middleware\Consume\MessageHandlerConsumeInterface;
-use Yiisoft\Queue\Middleware\Consume\MiddlewareConsumeInterface;
-use Yiisoft\Queue\Middleware\Consume\ConsumeRequest;
-
-final class TestMiddleware implements MiddlewareConsumeInterface
-{
-    public function __construct(private string $message = 'New middleware test data')
-    {
-    }
-
-    public function processConsume(ConsumeRequest $request, MessageHandlerConsumeInterface $handler): ConsumeRequest
-    {
-        return $request->withMessage(new Message('test', $this->message));
-    }
-}
diff --git a/tests/Unit/Middleware/FailureHandling/Implementation/ExponentialDelayMiddlewareTest.php b/tests/Unit/Middleware/FailureHandling/Implementation/ExponentialDelayMiddlewareTest.php
index 5d24f46a..18f01502 100644
--- a/tests/Unit/Middleware/FailureHandling/Implementation/ExponentialDelayMiddlewareTest.php
+++ b/tests/Unit/Middleware/FailureHandling/Implementation/ExponentialDelayMiddlewareTest.php
@@ -8,10 +8,10 @@
 use InvalidArgumentException;
 use PHPUnit\Framework\Attributes\DataProvider;
 use Yiisoft\Queue\Message\Message;
+use Yiisoft\Queue\Middleware\DelayMiddlewareInterface;
 use Yiisoft\Queue\Middleware\FailureHandling\FailureHandlingRequest;
 use Yiisoft\Queue\Middleware\FailureHandling\Implementation\ExponentialDelayMiddleware;
 use Yiisoft\Queue\Middleware\FailureHandling\MessageFailureHandlerInterface;
-use Yiisoft\Queue\Middleware\Push\Implementation\DelayMiddlewareInterface;
 use Yiisoft\Queue\QueueInterface;
 use Yiisoft\Queue\Tests\TestCase;
 
diff --git a/tests/Unit/Middleware/FailureHandling/Implementation/SendAgainMiddlewareTest.php b/tests/Unit/Middleware/FailureHandling/Implementation/SendAgainMiddlewareTest.php
index 57dc4eb9..1e4f5320 100644
--- a/tests/Unit/Middleware/FailureHandling/Implementation/SendAgainMiddlewareTest.php
+++ b/tests/Unit/Middleware/FailureHandling/Implementation/SendAgainMiddlewareTest.php
@@ -15,7 +15,7 @@
 use Yiisoft\Queue\Middleware\FailureHandling\Implementation\SendAgainMiddleware;
 use Yiisoft\Queue\Middleware\FailureHandling\MessageFailureHandlerInterface;
 use Yiisoft\Queue\Middleware\FailureHandling\MiddlewareFailureInterface;
-use Yiisoft\Queue\Middleware\Push\Implementation\DelayMiddlewareInterface;
+use Yiisoft\Queue\Middleware\DelayMiddlewareInterface;
 use Yiisoft\Queue\QueueInterface;
 use Yiisoft\Queue\Tests\TestCase;
 
diff --git a/tests/Unit/Middleware/Push/InvalidMiddlewareDefinitionExceptionTest.php b/tests/Unit/Middleware/InvalidMiddlewareDefinitionExceptionTest.php
similarity index 82%
rename from tests/Unit/Middleware/Push/InvalidMiddlewareDefinitionExceptionTest.php
rename to tests/Unit/Middleware/InvalidMiddlewareDefinitionExceptionTest.php
index 9cb940cf..408196e9 100644
--- a/tests/Unit/Middleware/Push/InvalidMiddlewareDefinitionExceptionTest.php
+++ b/tests/Unit/Middleware/InvalidMiddlewareDefinitionExceptionTest.php
@@ -2,13 +2,13 @@
 
 declare(strict_types=1);
 
-namespace Yiisoft\Queue\Tests\Unit\Middleware\Push;
+namespace Yiisoft\Queue\Tests\Unit\Middleware;
 
 use PHPUnit\Framework\Attributes\DataProvider;
 use PHPUnit\Framework\TestCase;
 use stdClass;
 use Yiisoft\Queue\Middleware\InvalidMiddlewareDefinitionException;
-use Yiisoft\Queue\Tests\Unit\Middleware\Push\Support\TestCallableMiddleware;
+use Yiisoft\Queue\Tests\Unit\Middleware\Support\TestCallableMiddleware;
 
 final class InvalidMiddlewareDefinitionExceptionTest extends TestCase
 {
@@ -21,15 +21,15 @@ public static function dataBase(): array
             ],
             [
                 new TestCallableMiddleware(),
-                'an instance of "Yiisoft\Queue\Tests\Unit\Middleware\Push\Support\TestCallableMiddleware"',
+                'an instance of "Yiisoft\Queue\Tests\Unit\Middleware\Support\TestCallableMiddleware"',
             ],
             [
                 [TestCallableMiddleware::class, 'notExistsAction'],
-                '["Yiisoft\Queue\Tests\Unit\Middleware\Push\Support\TestCallableMiddleware", "notExistsAction"]',
+                '["Yiisoft\Queue\Tests\Unit\Middleware\Support\TestCallableMiddleware", "notExistsAction"]',
             ],
             [
                 ['class' => TestCallableMiddleware::class, 'index'],
-                '["class" => "Yiisoft\Queue\Tests\Unit\Middleware\Push\Support\TestCallableMiddleware", "index"]',
+                '["class" => "Yiisoft\Queue\Tests\Unit\Middleware\Support\TestCallableMiddleware", "index"]',
             ],
         ];
     }
diff --git a/tests/Unit/Middleware/Push/MiddlewareDispatcherTest.php b/tests/Unit/Middleware/MiddlewareDispatcherTest.php
similarity index 72%
rename from tests/Unit/Middleware/Push/MiddlewareDispatcherTest.php
rename to tests/Unit/Middleware/MiddlewareDispatcherTest.php
index 713bab4a..ba389e5c 100644
--- a/tests/Unit/Middleware/Push/MiddlewareDispatcherTest.php
+++ b/tests/Unit/Middleware/MiddlewareDispatcherTest.php
@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Yiisoft\Queue\Tests\Unit\Middleware\Push;
+namespace Yiisoft\Queue\Tests\Unit\Middleware;
 
 use PHPUnit\Framework\Attributes\DataProvider;
 use PHPUnit\Framework\TestCase;
@@ -11,23 +11,23 @@
 use Yiisoft\Queue\Adapter\AdapterInterface;
 use Yiisoft\Queue\Message\Message;
 use Yiisoft\Queue\Middleware\CallableFactory;
-use Yiisoft\Queue\Middleware\Push\MessageHandlerPushInterface;
-use Yiisoft\Queue\Middleware\Push\MiddlewareFactoryPush;
-use Yiisoft\Queue\Middleware\Push\PushMiddlewareDispatcher;
-use Yiisoft\Queue\Middleware\Push\PushRequest;
+use Yiisoft\Queue\Middleware\MessageHandlerInterface;
+use Yiisoft\Queue\Middleware\MiddlewareFactory;
+use Yiisoft\Queue\Middleware\MiddlewareDispatcher;
+use Yiisoft\Queue\Middleware\Request;
 use Yiisoft\Queue\Tests\App\FakeAdapter;
-use Yiisoft\Queue\Tests\Unit\Middleware\Push\Support\TestCallableMiddleware;
-use Yiisoft\Queue\Tests\Unit\Middleware\Push\Support\TestMiddleware;
+use Yiisoft\Queue\Tests\Unit\Middleware\Support\TestCallableMiddleware;
+use Yiisoft\Queue\Tests\Unit\Middleware\Support\TestMiddleware;
 
 final class MiddlewareDispatcherTest extends TestCase
 {
     public function testCallableMiddlewareCalled(): void
     {
-        $request = $this->getPushRequest();
+        $request = $this->getRequest();
 
         $dispatcher = $this->createDispatcher()->withMiddlewares(
             [
-                static fn (PushRequest $request, AdapterInterface $adapter): PushRequest => $request
+                static fn (Request $request, AdapterInterface $adapter): Request => $request
                     ->withMessage(new Message('test', 'New closure test data'))
                     ->withAdapter($adapter->withChannel('closure-channel')),
             ]
@@ -44,7 +44,7 @@ public function testCallableMiddlewareCalled(): void
 
     public function testArrayMiddlewareCallableDefinition(): void
     {
-        $request = $this->getPushRequest();
+        $request = $this->getRequest();
         $container = $this->createContainer(
             [
                 TestCallableMiddleware::class => new TestCallableMiddleware(),
@@ -57,7 +57,7 @@ public function testArrayMiddlewareCallableDefinition(): void
 
     public function testFactoryArrayDefinition(): void
     {
-        $request = $this->getPushRequest();
+        $request = $this->getRequest();
         $container = $this->createContainer();
         $definition = [
             'class' => TestMiddleware::class,
@@ -70,14 +70,14 @@ public function testFactoryArrayDefinition(): void
 
     public function testMiddlewareFullStackCalled(): void
     {
-        $request = $this->getPushRequest();
+        $request = $this->getRequest();
 
-        $middleware1 = static function (PushRequest $request, MessageHandlerPushInterface $handler): PushRequest {
+        $middleware1 = static function (Request $request, MessageHandlerInterface $handler): Request {
             $request = $request->withMessage(new Message($request->getMessage()->getHandlerName(), 'new test data'));
 
-            return $handler->handlePush($request);
+            return $handler->handle($request);
         };
-        $middleware2 = static function (PushRequest $request, MessageHandlerPushInterface $handler): PushRequest {
+        $middleware2 = static function (Request $request, MessageHandlerInterface $handler): Request {
             /**
              * @noinspection NullPointerExceptionInspection
              *
@@ -85,7 +85,7 @@ public function testMiddlewareFullStackCalled(): void
              */
             $request = $request->withAdapter($request->getAdapter()->withChannel('new channel'));
 
-            return $handler->handlePush($request);
+            return $handler->handle($request);
         };
 
         $dispatcher = $this->createDispatcher()->withMiddlewares([$middleware1, $middleware2]);
@@ -101,10 +101,10 @@ public function testMiddlewareFullStackCalled(): void
 
     public function testMiddlewareStackInterrupted(): void
     {
-        $request = $this->getPushRequest();
+        $request = $this->getRequest();
 
-        $middleware1 = static fn (PushRequest $request, MessageHandlerPushInterface $handler): PushRequest => $request->withMessage(new Message($request->getMessage()->getHandlerName(), 'first'));
-        $middleware2 = static fn (PushRequest $request, MessageHandlerPushInterface $handler): PushRequest => $request->withMessage(new Message($request->getMessage()->getHandlerName(), 'second'));
+        $middleware1 = static fn (Request $request, MessageHandlerInterface $handler): Request => $request->withMessage(new Message($request->getMessage()->getHandlerName(), 'first'));
+        $middleware2 = static fn (Request $request, MessageHandlerInterface $handler): Request => $request->withMessage(new Message($request->getMessage()->getHandlerName(), 'second'));
 
         $dispatcher = $this->createDispatcher()->withMiddlewares([$middleware1, $middleware2]);
 
@@ -137,7 +137,7 @@ public function testImmutability(): void
 
     public function testResetStackOnWithMiddlewares(): void
     {
-        $request = $this->getPushRequest();
+        $request = $this->getRequest();
         $container = $this->createContainer(
             [
                 TestCallableMiddleware::class => new TestCallableMiddleware(),
@@ -156,10 +156,10 @@ public function testResetStackOnWithMiddlewares(): void
         self::assertSame('New middleware test data', $request->getMessage()->getData());
     }
 
-    private function getRequestHandler(): MessageHandlerPushInterface
+    private function getRequestHandler(): MessageHandlerInterface
     {
-        return new class () implements MessageHandlerPushInterface {
-            public function handlePush(PushRequest $request): PushRequest
+        return new class () implements MessageHandlerInterface {
+            public function handle(Request $request): Request
             {
                 return $request;
             }
@@ -168,12 +168,12 @@ public function handlePush(PushRequest $request): PushRequest
 
     private function createDispatcher(
         ContainerInterface $container = null,
-    ): PushMiddlewareDispatcher {
+    ): MiddlewareDispatcher {
         $container ??= $this->createContainer([AdapterInterface::class => new FakeAdapter()]);
         $callableFactory = new CallableFactory($container);
 
-        return new PushMiddlewareDispatcher(
-            new MiddlewareFactoryPush($container, $callableFactory),
+        return new MiddlewareDispatcher(
+            new MiddlewareFactory($container, $callableFactory),
         );
     }
 
@@ -182,8 +182,8 @@ private function createContainer(array $instances = []): ContainerInterface
         return new SimpleContainer($instances);
     }
 
-    private function getPushRequest(): PushRequest
+    private function getRequest(): Request
     {
-        return new PushRequest(new Message('handler', 'data'), new FakeAdapter());
+        return new Request(new Message('handler', 'data'), new FakeAdapter());
     }
 }
diff --git a/tests/Unit/Middleware/Push/MiddlewareFactoryTest.php b/tests/Unit/Middleware/MiddlewareFactoryTest.php
similarity index 65%
rename from tests/Unit/Middleware/Push/MiddlewareFactoryTest.php
rename to tests/Unit/Middleware/MiddlewareFactoryTest.php
index c68bc6db..3990ddb8 100644
--- a/tests/Unit/Middleware/Push/MiddlewareFactoryTest.php
+++ b/tests/Unit/Middleware/MiddlewareFactoryTest.php
@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Yiisoft\Queue\Tests\Unit\Middleware\Push;
+namespace Yiisoft\Queue\Tests\Unit\Middleware;
 
 use PHPUnit\Framework\Attributes\DataProvider;
 use PHPUnit\Framework\TestCase;
@@ -12,34 +12,34 @@
 use Yiisoft\Queue\Message\Message;
 use Yiisoft\Queue\Middleware\CallableFactory;
 use Yiisoft\Queue\Middleware\InvalidMiddlewareDefinitionException;
-use Yiisoft\Queue\Middleware\Push\MessageHandlerPushInterface;
-use Yiisoft\Queue\Middleware\Push\MiddlewareFactoryPush;
-use Yiisoft\Queue\Middleware\Push\MiddlewareFactoryPushInterface;
-use Yiisoft\Queue\Middleware\Push\MiddlewarePushInterface;
-use Yiisoft\Queue\Middleware\Push\PushRequest;
+use Yiisoft\Queue\Middleware\MessageHandlerInterface;
+use Yiisoft\Queue\Middleware\MiddlewareFactory;
+use Yiisoft\Queue\Middleware\MiddlewareFactoryInterface;
+use Yiisoft\Queue\Middleware\MiddlewareInterface;
+use Yiisoft\Queue\Middleware\Request;
 use Yiisoft\Queue\Tests\App\FakeAdapter;
-use Yiisoft\Queue\Tests\Unit\Middleware\Push\Support\InvalidController;
-use Yiisoft\Queue\Tests\Unit\Middleware\Push\Support\TestCallableMiddleware;
-use Yiisoft\Queue\Tests\Unit\Middleware\Push\Support\TestMiddleware;
+use Yiisoft\Queue\Tests\Unit\Middleware\Support\InvalidController;
+use Yiisoft\Queue\Tests\Unit\Middleware\Support\TestCallableMiddleware;
+use Yiisoft\Queue\Tests\Unit\Middleware\Support\TestMiddleware;
 
 final class MiddlewareFactoryTest extends TestCase
 {
     public function testCreateFromString(): void
     {
         $container = $this->getContainer([TestMiddleware::class => new TestMiddleware()]);
-        $middleware = $this->getMiddlewareFactory($container)->createPushMiddleware(TestMiddleware::class);
+        $middleware = $this->getMiddlewareFactory($container)->createMiddleware(TestMiddleware::class);
         self::assertInstanceOf(TestMiddleware::class, $middleware);
     }
 
     public function testCreateCallableFromArray(): void
     {
         $container = $this->getContainer([TestCallableMiddleware::class => new TestCallableMiddleware()]);
-        $middleware = $this->getMiddlewareFactory($container)->createPushMiddleware([TestCallableMiddleware::class, 'index']);
+        $middleware = $this->getMiddlewareFactory($container)->createMiddleware([TestCallableMiddleware::class, 'index']);
         self::assertSame(
             'New test data',
-            $middleware->processPush(
-                $this->getPushRequest(),
-                $this->createMock(MessageHandlerPushInterface::class)
+            $middleware->process(
+                $this->getRequest(),
+                $this->createMock(MessageHandlerInterface::class)
             )->getMessage()->getData(),
         );
     }
@@ -47,16 +47,16 @@ public function testCreateCallableFromArray(): void
     public function testCreateFromClosureResponse(): void
     {
         $container = $this->getContainer([TestCallableMiddleware::class => new TestCallableMiddleware()]);
-        $middleware = $this->getMiddlewareFactory($container)->createPushMiddleware(
-            static function (): PushRequest {
-                return new PushRequest(new Message('test', 'test data'), new FakeAdapter());
+        $middleware = $this->getMiddlewareFactory($container)->createMiddleware(
+            static function (): Request {
+                return new Request(new Message('test', 'test data'), new FakeAdapter());
             }
         );
         self::assertSame(
             'test data',
-            $middleware->processPush(
-                $this->getPushRequest(),
-                $this->createMock(MessageHandlerPushInterface::class)
+            $middleware->process(
+                $this->getRequest(),
+                $this->createMock(MessageHandlerInterface::class)
             )->getMessage()->getData()
         );
     }
@@ -64,16 +64,16 @@ static function (): PushRequest {
     public function testCreateFromClosureMiddleware(): void
     {
         $container = $this->getContainer([TestCallableMiddleware::class => new TestCallableMiddleware()]);
-        $middleware = $this->getMiddlewareFactory($container)->createPushMiddleware(
-            static function (): MiddlewarePushInterface {
+        $middleware = $this->getMiddlewareFactory($container)->createMiddleware(
+            static function (): MiddlewareInterface {
                 return new TestMiddleware();
             }
         );
         self::assertSame(
             'New middleware test data',
-            $middleware->processPush(
-                $this->getPushRequest(),
-                $this->createMock(MessageHandlerPushInterface::class)
+            $middleware->process(
+                $this->getRequest(),
+                $this->createMock(MessageHandlerInterface::class)
             )->getMessage()->getData()
         );
     }
@@ -81,12 +81,12 @@ static function (): MiddlewarePushInterface {
     public function testCreateWithUseParamsMiddleware(): void
     {
         $container = $this->getContainer([TestMiddleware::class => new TestMiddleware()]);
-        $middleware = $this->getMiddlewareFactory($container)->createPushMiddleware(TestMiddleware::class);
+        $middleware = $this->getMiddlewareFactory($container)->createMiddleware(TestMiddleware::class);
 
         self::assertSame(
             'New middleware test data',
-            $middleware->processPush(
-                $this->getPushRequest(),
+            $middleware->process(
+                $this->getRequest(),
                 $this->getRequestHandler()
             )->getMessage()->getData()
         );
@@ -95,12 +95,12 @@ public function testCreateWithUseParamsMiddleware(): void
     public function testCreateWithTestCallableMiddleware(): void
     {
         $container = $this->getContainer([TestCallableMiddleware::class => new TestCallableMiddleware()]);
-        $middleware = $this->getMiddlewareFactory($container)->createPushMiddleware([TestCallableMiddleware::class, 'index']);
-        $request = $this->getPushRequest();
+        $middleware = $this->getMiddlewareFactory($container)->createMiddleware([TestCallableMiddleware::class, 'index']);
+        $request = $this->getRequest();
 
         self::assertSame(
             'New test data',
-            $middleware->processPush(
+            $middleware->process(
                 $request,
                 $this->getRequestHandler()
             )->getMessage()->getData()
@@ -125,28 +125,28 @@ public static function invalidMiddlewareDefinitionProvider(): array
     public function testInvalidMiddleware(mixed $definition): void
     {
         $this->expectException(InvalidMiddlewareDefinitionException::class);
-        $this->getMiddlewareFactory()->createPushMiddleware($definition);
+        $this->getMiddlewareFactory()->createMiddleware($definition);
     }
 
     public function testInvalidMiddlewareWithWrongController(): void
     {
         $container = $this->getContainer([InvalidController::class => new InvalidController()]);
-        $middleware = $this->getMiddlewareFactory($container)->createPushMiddleware(
+        $middleware = $this->getMiddlewareFactory($container)->createMiddleware(
             [InvalidController::class, 'index']
         );
 
         $this->expectException(InvalidMiddlewareDefinitionException::class);
-        $middleware->processPush(
-            $this->getPushRequest(),
-            $this->createMock(MessageHandlerPushInterface::class)
+        $middleware->process(
+            $this->getRequest(),
+            $this->createMock(MessageHandlerInterface::class)
         );
     }
 
-    private function getMiddlewareFactory(ContainerInterface $container = null): MiddlewareFactoryPushInterface
+    private function getMiddlewareFactory(ContainerInterface $container = null): MiddlewareFactoryInterface
     {
         $container ??= $this->getContainer([AdapterInterface::class => new FakeAdapter()]);
 
-        return new MiddlewareFactoryPush($container, new CallableFactory($container));
+        return new MiddlewareFactory($container, new CallableFactory($container));
     }
 
     private function getContainer(array $instances = []): ContainerInterface
@@ -154,18 +154,18 @@ private function getContainer(array $instances = []): ContainerInterface
         return new SimpleContainer($instances);
     }
 
-    private function getRequestHandler(): MessageHandlerPushInterface
+    private function getRequestHandler(): MessageHandlerInterface
     {
-        return new class () implements MessageHandlerPushInterface {
-            public function handlePush(PushRequest $request): PushRequest
+        return new class () implements MessageHandlerInterface {
+            public function handle(Request $request): Request
             {
                 return $request;
             }
         };
     }
 
-    private function getPushRequest(): PushRequest
+    private function getRequest(): Request
     {
-        return new PushRequest(new Message('handler', 'data'), new FakeAdapter());
+        return new Request(new Message('handler', 'data'), new FakeAdapter());
     }
 }
diff --git a/tests/Unit/Middleware/Push/PushRequestTest.php b/tests/Unit/Middleware/Push/PushRequestTest.php
deleted file mode 100644
index 2c1533e5..00000000
--- a/tests/Unit/Middleware/Push/PushRequestTest.php
+++ /dev/null
@@ -1,22 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Yiisoft\Queue\Tests\Unit\Middleware\Push;
-
-use Yiisoft\Queue\Message\Message;
-use Yiisoft\Queue\Middleware\Push\PushRequest;
-use Yiisoft\Queue\Tests\App\FakeAdapter;
-use Yiisoft\Queue\Tests\TestCase;
-
-final class PushRequestTest extends TestCase
-{
-    public function testImmutable(): void
-    {
-        $message = new Message('test', 'test');
-        $pushRequest = new PushRequest($message, new FakeAdapter());
-
-        $this->assertNotSame($pushRequest, $pushRequest->withAdapter(new FakeAdapter()));
-        $this->assertNotSame($pushRequest, $pushRequest->withMessage($message));
-    }
-}
diff --git a/tests/Unit/Middleware/Push/Support/TestMiddleware.php b/tests/Unit/Middleware/Push/Support/TestMiddleware.php
deleted file mode 100644
index a15c24f0..00000000
--- a/tests/Unit/Middleware/Push/Support/TestMiddleware.php
+++ /dev/null
@@ -1,22 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Yiisoft\Queue\Tests\Unit\Middleware\Push\Support;
-
-use Yiisoft\Queue\Message\Message;
-use Yiisoft\Queue\Middleware\Push\MessageHandlerPushInterface;
-use Yiisoft\Queue\Middleware\Push\MiddlewarePushInterface;
-use Yiisoft\Queue\Middleware\Push\PushRequest;
-
-final class TestMiddleware implements MiddlewarePushInterface
-{
-    public function __construct(private string $message = 'New middleware test data')
-    {
-    }
-
-    public function processPush(PushRequest $request, MessageHandlerPushInterface $handler): PushRequest
-    {
-        return $request->withMessage(new Message('test', $this->message));
-    }
-}
diff --git a/tests/Unit/Middleware/PushRequestTest.php b/tests/Unit/Middleware/PushRequestTest.php
new file mode 100644
index 00000000..5bee6569
--- /dev/null
+++ b/tests/Unit/Middleware/PushRequestTest.php
@@ -0,0 +1,22 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Yiisoft\Queue\Tests\Unit\Middleware;
+
+use Yiisoft\Queue\Message\Message;
+use Yiisoft\Queue\Middleware\Request;
+use Yiisoft\Queue\Tests\App\FakeAdapter;
+use Yiisoft\Queue\Tests\TestCase;
+
+final class PushRequestTest extends TestCase
+{
+    public function testImmutable(): void
+    {
+        $message = new Message('test', 'test');
+        $Request = new Request($message, new FakeAdapter());
+
+        $this->assertNotSame($Request, $Request->withAdapter(new FakeAdapter()));
+        $this->assertNotSame($Request, $Request->withMessage($message));
+    }
+}
diff --git a/tests/Unit/Middleware/Push/Support/InvalidController.php b/tests/Unit/Middleware/Support/InvalidController.php
similarity index 68%
rename from tests/Unit/Middleware/Push/Support/InvalidController.php
rename to tests/Unit/Middleware/Support/InvalidController.php
index 95642cfb..14006ccf 100644
--- a/tests/Unit/Middleware/Push/Support/InvalidController.php
+++ b/tests/Unit/Middleware/Support/InvalidController.php
@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Yiisoft\Queue\Tests\Unit\Middleware\Push\Support;
+namespace Yiisoft\Queue\Tests\Unit\Middleware\Support;
 
 final class InvalidController
 {
diff --git a/tests/Unit/Middleware/Push/Support/TestCallableMiddleware.php b/tests/Unit/Middleware/Support/TestCallableMiddleware.php
similarity index 53%
rename from tests/Unit/Middleware/Push/Support/TestCallableMiddleware.php
rename to tests/Unit/Middleware/Support/TestCallableMiddleware.php
index 035ed999..1c1eeffd 100644
--- a/tests/Unit/Middleware/Push/Support/TestCallableMiddleware.php
+++ b/tests/Unit/Middleware/Support/TestCallableMiddleware.php
@@ -2,14 +2,14 @@
 
 declare(strict_types=1);
 
-namespace Yiisoft\Queue\Tests\Unit\Middleware\Push\Support;
+namespace Yiisoft\Queue\Tests\Unit\Middleware\Support;
 
 use Yiisoft\Queue\Message\Message;
-use Yiisoft\Queue\Middleware\Push\PushRequest;
+use Yiisoft\Queue\Middleware\Request;
 
 final class TestCallableMiddleware
 {
-    public function index(PushRequest $request): PushRequest
+    public function index(Request $request): Request
     {
         return $request->withMessage(new Message('test', 'New test data'));
     }
diff --git a/tests/Unit/Middleware/Support/TestMiddleware.php b/tests/Unit/Middleware/Support/TestMiddleware.php
new file mode 100644
index 00000000..1225678b
--- /dev/null
+++ b/tests/Unit/Middleware/Support/TestMiddleware.php
@@ -0,0 +1,22 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Yiisoft\Queue\Tests\Unit\Middleware\Support;
+
+use Yiisoft\Queue\Message\Message;
+use Yiisoft\Queue\Middleware\MessageHandlerInterface;
+use Yiisoft\Queue\Middleware\MiddlewareInterface;
+use Yiisoft\Queue\Middleware\Request;
+
+final class TestMiddleware implements MiddlewareInterface
+{
+    public function __construct(private string $message = 'New middleware test data')
+    {
+    }
+
+    public function process(Request $request, MessageHandlerInterface $handler): Request
+    {
+        return $request->withMessage(new Message('test', $this->message));
+    }
+}
diff --git a/tests/Unit/WorkerTest.php b/tests/Unit/WorkerTest.php
index c9ae1d6b..940f0afa 100644
--- a/tests/Unit/WorkerTest.php
+++ b/tests/Unit/WorkerTest.php
@@ -7,13 +7,13 @@
 use Psr\Container\ContainerInterface;
 use Psr\Log\LoggerInterface;
 use Yiisoft\Injector\Injector;
+use Yiisoft\Queue\Middleware\MiddlewareDispatcher;
+use Yiisoft\Queue\Middleware\MiddlewareFactoryInterface;
 use Yiisoft\Test\Support\Container\SimpleContainer;
 use Yiisoft\Test\Support\Log\SimpleLogger;
 use Yiisoft\Queue\Exception\JobFailureException;
 use Yiisoft\Queue\Message\Message;
 use Yiisoft\Queue\Message\MessageInterface;
-use Yiisoft\Queue\Middleware\Consume\ConsumeMiddlewareDispatcher;
-use Yiisoft\Queue\Middleware\Consume\MiddlewareFactoryConsumeInterface;
 use Yiisoft\Queue\Middleware\FailureHandling\FailureMiddlewareDispatcher;
 use Yiisoft\Queue\Middleware\FailureHandling\MiddlewareFactoryFailureInterface;
 use Yiisoft\Queue\QueueInterface;
@@ -195,7 +195,7 @@ private function createWorkerByParams(
             $logger,
             new Injector($container),
             $container,
-            new ConsumeMiddlewareDispatcher($this->createMock(MiddlewareFactoryConsumeInterface::class)),
+            new MiddlewareDispatcher($this->createMock(MiddlewareFactoryInterface::class)),
             new FailureMiddlewareDispatcher($this->createMock(MiddlewareFactoryFailureInterface::class), []),
         );
     }