Xervice\EventRabbitMq\Business\Plugin\Listener\QueueListener

Complexity

Total Complexity

6

Size/Duplication

Total Lines	36
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	handleMessage()	0	16	4
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\EventRabbitMq\Business\Exception\EventFailException;
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();

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

                $this->sendAck($channel, $message);
            } catch (EventFailException $exception) {
                $this->sendNack($channel, $message);
            }
        }
    }

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

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