123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116 |
- <?php
- /**
- * Copyright © Magento, Inc. All rights reserved.
- * See COPYING.txt for license details.
- */
- namespace Magento\Framework\MessageQueue\Consumer\Config;
- use Magento\Framework\MessageQueue\Consumer\Config\ConsumerConfigItem\Handler\Iterator as HandlerIterator;
- use Magento\Framework\MessageQueue\Consumer\Config\ConsumerConfigItem\Handler\IteratorFactory as HandlerIteratorFactory;
- /**
- * {@inheritdoc}
- */
- class ConsumerConfigItem implements ConsumerConfigItemInterface
- {
- /**
- * @var string
- */
- private $name;
- /**
- * @var string
- */
- private $connection;
- /**
- * @var string
- */
- private $queue;
- /**
- * @var string
- */
- private $consumerInstance;
- /**
- * @var HandlerIterator
- */
- private $handlers;
- /**
- * @var string
- */
- private $maxMessages;
- /**
- * Initialize dependencies.
- *
- * @param HandlerIteratorFactory $handlerIteratorFactory
- */
- public function __construct(HandlerIteratorFactory $handlerIteratorFactory)
- {
- $this->handlers = $handlerIteratorFactory->create();
- }
- /**
- * {@inheritdoc}
- */
- public function getName()
- {
- return $this->name;
- }
- /**
- * {@inheritdoc}
- */
- public function getConnection()
- {
- return $this->connection;
- }
- /**
- * {@inheritdoc}
- */
- public function getQueue()
- {
- return $this->queue;
- }
- /**
- * {@inheritdoc}
- */
- public function getConsumerInstance()
- {
- return $this->consumerInstance;
- }
- /**
- * {@inheritdoc}
- */
- public function getHandlers()
- {
- return $this->handlers;
- }
- /**
- * {@inheritdoc}
- */
- public function getMaxMessages()
- {
- return $this->maxMessages;
- }
- /**
- * {@inheritdoc}
- */
- public function setData(array $data)
- {
- $this->name = $data['name'];
- $this->connection = $data['connection'];
- $this->queue = $data['queue'];
- $this->consumerInstance = $data['consumerInstance'];
- $this->maxMessages = $data['maxMessages'];
- $this->handlers->setData($data['handlers']);
- }
- }
|