for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
declare(strict_types=1);
namespace Yiisoft\Queue\Message;
use Yiisoft\Arrays\ArrayHelper;
abstract class AbstractEnvelope implements EnvelopeInterface
{
protected array $metadata = [];
private MessageInterface $message;
public function __construct(MessageInterface $message)
$this->message = $message instanceof EnvelopeInterface ? $message->getMessage() : $message;
$this->metadata = $message->getMetadata();
if (is_array($this->metadata[EnvelopeInterface::ENVELOPE_STACK_KEY])) {
$this->metadata[EnvelopeInterface::ENVELOPE_STACK_KEY] = array_merge(
[static::class],
array_filter(
$this->metadata[EnvelopeInterface::ENVELOPE_STACK_KEY],
static fn(string $class) => $class !== static::class,
)
);
} else {
$this->metadata[EnvelopeInterface::ENVELOPE_STACK_KEY] = [static::class];
}
public function getMessage(): MessageInterface
return $this->message;
public function getHandlerName(): string
return $this->message->getHandlerName();
public function getData(): mixed
return $this->message->getData();
public function getMetadata(): array
return ArrayHelper::merge(
$this->metadata,
$this->getEnvelopeMetadata(),
/**
* Metadata of the envelope
*
* @return array
*/
abstract protected function getEnvelopeMetadata(): array;
yiisoft /
queue
