Xervice\EventRabbitMq\Communication\Plugin\Listener\QueueListener::handleMessage()

Complexity

Conditions	3
Paths	3

Size

Total Lines	13
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function handleMessage(
        RabbitMqMessageCollectionDataProvider $collectionDataProvider,
        AMQPChannel $channel
    ): void {

        foreach ($collectionDataProvider->getMessages() as $message) {
            $event = $message->getMessage();

            if ($event->hasName()) {

The method hasName() does not exist on Xervice\DataProvider\Business\Model\DataProvider\DataProviderInterface. It seems like you code against a sub-type of Xervice\DataProvider\Business\Model\DataProvider\DataProviderInterface such as DataProvider\EventDataProvider or DataProvider\RabbitMqExchangeDataProvider or DataProvider\RabbitMqQueueDataProvider or DataProvider\EventDataProvider or DataProvider\RabbitMqExchangeDataProvider or DataProvider\RabbitMqQueueDataProvider.

                $this->getFactory()->getEventFacade()->eventToListener($event);
            }

            $this->sendAck($channel, $message);
        }
}