0 follower

Final Class Yiisoft\Queue\Debug\QueueDecorator

All Classes | Methods
InheritanceYiisoft\Queue\Debug\QueueDecorator
ImplementsYiisoft\Queue\QueueInterface

Public Methods

Hide inherited methods

Method Description Defined By
__construct() Yiisoft\Queue\Debug\QueueDecorator
getName() Yiisoft\Queue\Debug\QueueDecorator
listen() Yiisoft\Queue\Debug\QueueDecorator
push() Yiisoft\Queue\Debug\QueueDecorator
run() Yiisoft\Queue\Debug\QueueDecorator
status() Yiisoft\Queue\Debug\QueueDecorator
withMiddlewares() Yiisoft\Queue\Debug\QueueDecorator
withMiddlewaresAdded() Yiisoft\Queue\Debug\QueueDecorator

Method Details

Hide inherited methods

__construct() public method

public mixed __construct ( Yiisoft\Queue\QueueInterface $queue, Yiisoft\Queue\Debug\QueueCollector $collector )
$queue Yiisoft\Queue\QueueInterface
$collector Yiisoft\Queue\Debug\QueueCollector 

                public function __construct(
    private readonly QueueInterface $queue,
    private readonly QueueCollector $collector,
) {}
getName() public method

public string getName ( )

                public function getName(): string
{
    return $this->queue->getName();
}
listen() public method

public void listen ( )

                public function listen(): void
{
    $this->queue->listen();
}
push() public method

public Yiisoft\Queue\Message\MessageInterface push ( Yiisoft\Queue\Message\MessageInterface $message )
$message Yiisoft\Queue\Message\MessageInterface 

                public function push(MessageInterface $message): MessageInterface
{
    /** @psalm-var array{file: string, line: int} $callStack */
    $callStack = debug_backtrace()[0];
    $message = $this->queue->push($message);
    $this->collector->collectPush($this->queue->getName(), $message, $callStack['file'] . ':' . $callStack['line']);
    return $message;
}
run() public method

public integer run ( integer $max = 0 )
$max integer 

                public function run(int $max = 0): int
{
    return $this->queue->run($max);
}
status() public method

public \Yiisoft\Queue\MessageStatus status ( string|integer $id )
$id string|integer 

                public function status(string|int $id): MessageStatus
{
    /** @psalm-var array{file: string, line: int} $callStack */
    $callStack = debug_backtrace()[0];
    $result = $this->queue->status($id);
    $this->collector->collectStatus((string) $id, $result, $callStack['file'] . ':' . $callStack['line']);
    return $result;
}
withMiddlewares() public method

public self withMiddlewares ( mixed $middlewareDefinitions )
$middlewareDefinitions mixed 

                public function withMiddlewares(mixed ...$middlewareDefinitions): self
{
    return new self($this->queue->withMiddlewares(...$middlewareDefinitions), $this->collector);
}
withMiddlewaresAdded() public method

public self withMiddlewaresAdded ( mixed $middlewareDefinitions )
$middlewareDefinitions mixed 

                public function withMiddlewaresAdded(mixed ...$middlewareDefinitions): self
{
    return new self($this->queue->withMiddlewaresAdded(...$middlewareDefinitions), $this->collector);
}