WebhookProcessor::getSubscribedCommand() - Code Metrics - Inspection of "Up" - paymaxi/webhooks - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#7)

by Dmytro

created 2017-10-24 21:17 UTC

WebhookProcessor::getSubscribedCommand() A

↳ Parent: WebhookProcessor

Complexity

Conditions	1
Paths	1

Size

Total Lines	11
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	11
rs	9.4285
c	0
b	0
f	0
cc	1
eloc	6
nc	1
nop	0

<?php
declare(strict_types=1);

namespace Webhook\Bundle\Service;


use Enqueue\Client\CommandSubscriberInterface;
use Interop\Queue\PsrContext;
use Interop\Queue\PsrMessage;
use Interop\Queue\PsrProcessor;

/**
 * Class WebhookProcessor
 *
 * @package Webhook\Bundle\Service
 */
final class WebhookProcessor implements PsrProcessor, CommandSubscriberInterface
{
    public const NAME = 'webhook-processor';

    /** @var WebhookConsumer */
    private $consumer;

    /**
     * RatesProcessor constructor.
     *
     * @param WebhookConsumer $consumer
     */
    public function __construct(WebhookConsumer $consumer)
    {
        $this->consumer = $consumer;
    }

    /**
     * @param PsrMessage $message
     * @param PsrContext $context
     *
     * @return string
     */
    public function process(PsrMessage $message, PsrContext $context): string
    {
        $id = $message->getBody();

        $this->consumer->consume($id);

        return self::ACK;
    }

    /**
     * @return array
     */
    public static function getSubscribedCommand(): array
    {
        return [
            'processorName' => self::NAME,

            // these are optional, setting these option we make the migration smooth and backward compatible.
            'queueName' => 'webhooks',
            'queueNameHardcoded' => true,
            'exclusive' => true,
        ];
    }
}


1			<?php
2			declare(strict_types=1);
3
4			namespace Webhook\Bundle\Service;
5
6
7			use Enqueue\Client\CommandSubscriberInterface;
8			use Interop\Queue\PsrContext;
9			use Interop\Queue\PsrMessage;
10			use Interop\Queue\PsrProcessor;
11
12			/**
13			* Class WebhookProcessor
14			*
15			* @package Webhook\Bundle\Service
16			*/
17			final class WebhookProcessor implements PsrProcessor, CommandSubscriberInterface
18			{
19			public const NAME = 'webhook-processor';
20
21			/** @var WebhookConsumer */
22			private $consumer;
23
24			/**
25			* RatesProcessor constructor.
26			*
27			* @param WebhookConsumer $consumer
28			*/
29			public function __construct(WebhookConsumer $consumer)
30			{
31			$this->consumer = $consumer;
32			}
33
34			/**
35			* @param PsrMessage $message
36			* @param PsrContext $context
37			*
38			* @return string
39			*/
40			public function process(PsrMessage $message, PsrContext $context): string
41			{
42			$id = $message->getBody();
43
44			$this->consumer->consume($id);
45
46			return self::ACK;
47			}
48
49			/**
50			* @return array
51			*/
52			public static function getSubscribedCommand(): array
53			{
54			return [
55			'processorName' => self::NAME,
56
57			// these are optional, setting these option we make the migration smooth and backward compatible.
58			'queueName' => 'webhooks',
59			'queueNameHardcoded' => true,
60			'exclusive' => true,
61			];
62			}
63			}
64

paymaxi / webhooks

Pull Request — master (#7)

WebhookProcessor::getSubscribedCommand() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like