AbstractListener::sendAck() - Code Metrics - xervice/rabbitmq - Measure and Improve Code Quality continuously with Scrutinizer

AbstractListener::sendAck() A
last analyzed 2019-04-15 07:08 UTC

↳ Parent: AbstractListener

Complexity

Conditions	1
Paths	1

Size

Total Lines	7
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	2
CRAP Score	1

Importance

Changes

Metric	Value
cc	1
eloc	1
nc	1
nop	3
dl	0
loc	7
ccs	2
cts	2
cp	1
crap	1
rs	10
c	0
b	0
f	0

<?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);
    }
}

1		<?php
2		declare(strict_types=1);
3
4		namespace Xervice\RabbitMQ\Business\Model\Worker\Listener;
5
6
7		use DataProvider\RabbitMqMessageDataProvider;
8		use PhpAmqpLib\Channel\AMQPChannel;
9		use Xervice\Core\Plugin\AbstractBusinessPlugin;
10		use Xervice\RabbitMQ\Business\Dependency\Worker\Listener\ListenerInterface;
11
12		abstract class AbstractListener extends AbstractBusinessPlugin implements ListenerInterface
13		{
14		protected const DEFAULT_CHUNKSIZE = 100;
15
16		/**
17		* @return int
18		*/
19		public function getChunkSize() : int
20		{
21		return self::DEFAULT_CHUNKSIZE;
22		}
23
24		/**
25		* @param \PhpAmqpLib\Channel\AMQPChannel $channel
26		* @param \DataProvider\RabbitMqMessageDataProvider $messageDataProvider
27		*/
28	2	public function sendAck(
29		AMQPChannel $channel,
30		RabbitMqMessageDataProvider $messageDataProvider,
31		bool $multiple = false
32		): void
33		{
34	2	$channel->basic_ack($messageDataProvider->getDeliveryTag(), $multiple);
35	2	}
36
37		/**
38		* @param \PhpAmqpLib\Channel\AMQPChannel $channel
39		* @param \DataProvider\RabbitMqMessageDataProvider $messageDataProvider
40		*/
41		public function sendNack(
42		AMQPChannel $channel,
43		RabbitMqMessageDataProvider $messageDataProvider,
44		bool $multiple = false,
45		bool $requeue = true
46		): void
47		{
48		$channel->basic_nack($messageDataProvider->getDeliveryTag(), $multiple, $requeue);
49		}
50		}

xervice / rabbitmq

AbstractListener::sendAck() A last analyzed 2019-04-15 07:08 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

AbstractListener::sendAck() A
last analyzed 2019-04-15 07:08 UTC