1234567891011121314151617181920212223242526272829303132333435363738394041424344454647 |
- <?php
- /*
- * This file is part of the Symfony package.
- *
- * (c) Fabien Potencier <fabien@symfony.com>
- *
- * For the full copyright and license information, please view the LICENSE
- * file that was distributed with this source code.
- */
- namespace Symfony\Component\Messenger;
- /**
- * @author Oleg Krasavin <okwinza@gmail.com>
- */
- final class WorkerMetadata
- {
- private $metadata;
- public function __construct(array $metadata)
- {
- $this->metadata = $metadata;
- }
- public function set(array $newMetadata): void
- {
- $this->metadata = array_merge($this->metadata, $newMetadata);
- }
- /**
- * Returns the queue names the worker consumes from, if "--queues" option was used.
- * Returns null otherwise.
- */
- public function getQueueNames(): ?array
- {
- return $this->metadata['queueNames'] ?? null;
- }
- /**
- * Returns an array of unique identifiers for transport receivers the worker consumes from.
- */
- public function getTransportNames(): array
- {
- return $this->metadata['transportNames'] ?? [];
- }
- }
|