ConsumerConfigItem.php 2.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116
  1. <?php
  2. /**
  3. * Copyright © Magento, Inc. All rights reserved.
  4. * See COPYING.txt for license details.
  5. */
  6. namespace Magento\Framework\MessageQueue\Consumer\Config;
  7. use Magento\Framework\MessageQueue\Consumer\Config\ConsumerConfigItem\Handler\Iterator as HandlerIterator;
  8. use Magento\Framework\MessageQueue\Consumer\Config\ConsumerConfigItem\Handler\IteratorFactory as HandlerIteratorFactory;
  9. /**
  10. * {@inheritdoc}
  11. */
  12. class ConsumerConfigItem implements ConsumerConfigItemInterface
  13. {
  14. /**
  15. * @var string
  16. */
  17. private $name;
  18. /**
  19. * @var string
  20. */
  21. private $connection;
  22. /**
  23. * @var string
  24. */
  25. private $queue;
  26. /**
  27. * @var string
  28. */
  29. private $consumerInstance;
  30. /**
  31. * @var HandlerIterator
  32. */
  33. private $handlers;
  34. /**
  35. * @var string
  36. */
  37. private $maxMessages;
  38. /**
  39. * Initialize dependencies.
  40. *
  41. * @param HandlerIteratorFactory $handlerIteratorFactory
  42. */
  43. public function __construct(HandlerIteratorFactory $handlerIteratorFactory)
  44. {
  45. $this->handlers = $handlerIteratorFactory->create();
  46. }
  47. /**
  48. * {@inheritdoc}
  49. */
  50. public function getName()
  51. {
  52. return $this->name;
  53. }
  54. /**
  55. * {@inheritdoc}
  56. */
  57. public function getConnection()
  58. {
  59. return $this->connection;
  60. }
  61. /**
  62. * {@inheritdoc}
  63. */
  64. public function getQueue()
  65. {
  66. return $this->queue;
  67. }
  68. /**
  69. * {@inheritdoc}
  70. */
  71. public function getConsumerInstance()
  72. {
  73. return $this->consumerInstance;
  74. }
  75. /**
  76. * {@inheritdoc}
  77. */
  78. public function getHandlers()
  79. {
  80. return $this->handlers;
  81. }
  82. /**
  83. * {@inheritdoc}
  84. */
  85. public function getMaxMessages()
  86. {
  87. return $this->maxMessages;
  88. }
  89. /**
  90. * {@inheritdoc}
  91. */
  92. public function setData(array $data)
  93. {
  94. $this->name = $data['name'];
  95. $this->connection = $data['connection'];
  96. $this->queue = $data['queue'];
  97. $this->consumerInstance = $data['consumerInstance'];
  98. $this->maxMessages = $data['maxMessages'];
  99. $this->handlers->setData($data['handlers']);
  100. }
  101. }