RequiredFields.php

Go to the documentation of this file.

<?php
namespace Magento\Framework\MessageQueue\Consumer\Config\Validator;

use Magento\Framework\MessageQueue\Consumer\Config\ValidatorInterface;

class RequiredFields implements ValidatorInterface
{
    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)
                    );
                }
            }
        }
    }
}