12345678910111213141516171819202122232425262728293031 |
- <?php
- /**
- * Copyright © Magento, Inc. All rights reserved.
- * See COPYING.txt for license details.
- */
- namespace Magento\Framework\MessageQueue\Consumer\Config\Validator;
- use Magento\Framework\MessageQueue\Consumer\Config\ValidatorInterface;
- /**
- * Consumer config data validator for required fields.
- */
- class RequiredFields implements ValidatorInterface
- {
- /**
- * {@inheritdoc}
- */
- public function validate($configData)
- {
- foreach ($configData as $consumerName => $consumerConfig) {
- $requiredFields = ['name', 'queue', 'handlers', 'consumerInstance', 'connection', 'maxMessages'];
- foreach ($requiredFields as $fieldName) {
- if (!array_key_exists($fieldName, $consumerConfig)) {
- throw new \LogicException(
- sprintf("'%s' field must be specified for consumer '%s'", $fieldName, $consumerName)
- );
- }
- }
- }
- }
- }
|