0 follower

Final Class Yiisoft\Queue\Middleware\Consume\MiddlewareConsumeStack

All Classes | Methods

Inheritance	Yiisoft\Queue\Middleware\Consume\MiddlewareConsumeStack
Implements	Yiisoft\Queue\Middleware\Consume\MessageHandlerConsumeInterface

Public Methods

Hide inherited methods

Method	Description	Defined By
__construct()		Yiisoft\Queue\Middleware\Consume\MiddlewareConsumeStack
handleConsume()		Yiisoft\Queue\Middleware\Consume\MiddlewareConsumeStack

Method Details

Hide inherited methods

__construct() public method

public __construct( Closure[] $middlewares, Yiisoft\Queue\Middleware\Consume\MessageHandlerConsumeInterface $finishHandler ): mixed
$middlewares	Closure[]	Middlewares.
$finishHandler	Yiisoft\Queue\Middleware\Consume\MessageHandlerConsumeInterface	Fallback handler events.

Source code

                public function __construct(
    private readonly array $middlewares,
    private readonly MessageHandlerConsumeInterface $finishHandler,
) {}

handleConsume() public method

public handleConsume( Yiisoft\Queue\Middleware\Consume\ConsumeRequest $request ): Yiisoft\Queue\Middleware\Consume\ConsumeRequest
$request	Yiisoft\Queue\Middleware\Consume\ConsumeRequest

Source code

                public function handleConsume(ConsumeRequest $request): ConsumeRequest
{
    if ($this->stack === null) {
        $this->build();
    }
    /** @psalm-suppress PossiblyNullReference */
    return $this->stack->handleConsume($request);
}