Xervice\RabbitMQ\Business\Model\Worker\Listener\AbstractListener

Complexity

Total Complexity

3

Size/Duplication

Total Lines	37
Duplicated Lines	0 %

Test Coverage

Coverage

42.86%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	getChunkSize()	0	3	1
A	sendAck()	0	7	1
A	sendNack()	0	8	1

<?php
declare(strict_types=1);

namespace Xervice\RabbitMQ\Business\Model\Worker\Listener;


use DataProvider\RabbitMqMessageDataProvider;
use PhpAmqpLib\Channel\AMQPChannel;
use Xervice\Core\Plugin\AbstractBusinessPlugin;
use Xervice\RabbitMQ\Business\Dependency\Worker\Listener\ListenerInterface;

abstract class AbstractListener extends AbstractBusinessPlugin implements ListenerInterface
{
    protected const DEFAULT_CHUNKSIZE = 100;

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

    /**
     * @param \PhpAmqpLib\Channel\AMQPChannel $channel
     * @param \DataProvider\RabbitMqMessageDataProvider $messageDataProvider
     */
    public function sendAck(
        AMQPChannel $channel,
        RabbitMqMessageDataProvider $messageDataProvider,
        bool $multiple = false
    ): void
    {
        $channel->basic_ack($messageDataProvider->getDeliveryTag(), $multiple);
    }

    /**
     * @param \PhpAmqpLib\Channel\AMQPChannel $channel
     * @param \DataProvider\RabbitMqMessageDataProvider $messageDataProvider
     */
    public function sendNack(
        AMQPChannel $channel,
        RabbitMqMessageDataProvider $messageDataProvider,
        bool $multiple = false,
        bool $requeue = true
    ): void
    {
        $channel->basic_nack($messageDataProvider->getDeliveryTag(), $multiple, $requeue);
    }
}