ConsumerInstance.php

Go to the documentation of this file.

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

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

class ConsumerInstance implements ValidatorInterface
{
    public function validate($configData)
    {
        foreach ($configData as $consumerConfig) {
            $this->validateConsumerInstance($consumerConfig);
        }
    }

    private function validateConsumerInstance($consumerConfig)
    {
        $consumerInstance = $consumerConfig['consumerInstance'];
        if ($consumerInstance == ConsumerInterface::class) {
            return;
        }
        if (!class_exists($consumerInstance)) {
            throw new \LogicException(
                sprintf(
                    "'%s' does not exist and thus cannot be used as 'consumerInstance' for '%s' consumer.",
                    $consumerInstance,
                    $consumerConfig['name'],
                    ConsumerInterface::class
                )
            );
        }
        $implementedInterfaces = class_implements($consumerInstance);
        if (!in_array(ConsumerInterface::class, $implementedInterfaces)) {
            throw new \LogicException(
                sprintf(
                    "'%s' cannot be specified as 'consumerInstance' for '%s' consumer,"
                    . " unless it implements '%s' interface",
                    $consumerInstance,
                    $consumerConfig['name'],
                    ConsumerInterface::class
                )
            );
        }
    }
}