Xervice\EventRabbitMq\Communication\Plugin\Listener\QueueListener

Complexity

Total Complexity

5

Size/Duplication

Total Lines	33
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	getChunkSize()	0	3	1
A	getQueueName()	0	3	1
A	handleMessage()	0	13	3

<?php


namespace Xervice\EventRabbitMq\Communication\Plugin\Listener;


use DataProvider\EventDataProvider;
use DataProvider\RabbitMqMessageCollectionDataProvider;
use PhpAmqpLib\Channel\AMQPChannel;
use Xervice\RabbitMQ\Worker\Listener\AbstractListener;

The type Xervice\RabbitMQ\Worker\Listener\AbstractListener was not found. Maybe you did not declare it correctly or list all dependencies?

/**
 * @method \Xervice\EventRabbitMq\EventRabbitMqFactory getFactory()
 */
class QueueListener extends AbstractListener
{
    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);
        }
    }

    /**
     * @return string
     * @throws \Core\Locator\Dynamic\ServiceNotParseable
     */
    public function getQueueName(): string
    {
        return $this->getFactory()->createEventQueue()->getName();
    }

    /**
     * @return int
     */
    public function getChunkSize(): int
    {
        return 1000;
    }
}