Final Class Yiisoft\Queue\Debug\QueueProducerDecorator
| Inheritance | Yiisoft\ |
|---|---|
| Implements | Yiisoft\ |
Public Methods
Method Details
| public mixed __construct ( Yiisoft\ | ||
| $queue | Yiisoft\ |
|
| $collector | Yiisoft\ |
|
public function __construct(private readonly QueueProducerInterface $queue, private readonly QueueCollector $collector) {}
| public string getQueueName ( ) |
public function getQueueName(): string
{
return $this->queue->getQueueName();
}
| public Yiisoft\ | ||
| $message | Yiisoft\ |
|
public function push(MessageInterface $message): MessageInterface
{ /** @psalm-var array{file: string, line: int} $stack */ $stack = debug_backtrace()[0];
$message = $this->queue->push($message);
$this->collector->collectPush($this->queue->getQueueName(), $message, $stack['file'] . ':' . $stack['line']);
return $message;
}
| public \ | ||
| $id | string|integer | |
public function status(string|int $id): MessageStatus
{ /** @psalm-var array{file: string, line: int} $stack */ $stack = debug_backtrace()[0];
$result = $this->queue->status($id);
$this->collector->collectStatus((string) $id, $result, $stack['file'] . ':' . $stack['line']);
return $result;
}
User Contributed Notes
Leave a comment
Join the conversation to share a note.