Xervice\EventRabbitMq\Business\Plugin\Listener\QueueListener

Complexity

Total Complexity

5

Size/Duplication

Total Lines	32
Duplicated Lines	0 %

Test Coverage

Coverage

63.64%

Importance

Changes

0

3 Methods

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

<?php


namespace Xervice\EventRabbitMq\Business\Plugin\Listener;


use DataProvider\RabbitMqMessageCollectionDataProvider;

The type DataProvider\RabbitMqMessageCollectionDataProvider was not found. Maybe you did not declare it correctly or list all dependencies?

use PhpAmqpLib\Channel\AMQPChannel;
use Xervice\RabbitMQ\Business\Model\Worker\Listener\AbstractListener;

/**
 * @method \Xervice\EventRabbitMq\Business\EventRabbitMqBusinessFactory getFactory()
 */
class QueueListener extends AbstractListener
{
    public function handleMessage(
        RabbitMqMessageCollectionDataProvider $collectionDataProvider,
        AMQPChannel $channel
    ): void {

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

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

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

    /**
     * @return string
     */
    public function getQueueName(): string
    {
        return $this->getFactory()->createEventQueue()->getName();
    }

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