SimpleBusProcessor::process() - Code Metrics - damax-solutions/enqueue-simple-bus-queue-interop - Measure and Improve Code Quality continuously with Scrutinizer

SimpleBusProcessor::process() A
last analyzed 2019-02-16 20:45 UTC

↳ Parent: SimpleBusProcessor

Complexity

Conditions	3
Paths	3

Size

Total Lines	13
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	8
dl	0
loc	13
rs	10
c	0
b	0
f	0
cc	3
nc	3
nop	2

<?php

declare(strict_types=1);

namespace Enqueue\SimpleBus;

use Interop\Queue\Context;
use Interop\Queue\Exception\InvalidMessageException;
use Interop\Queue\Message;
use Interop\Queue\Processor;
use SimpleBus\Asynchronous\Consumer\SerializedEnvelopeConsumer;
use Throwable;

final class SimpleBusProcessor implements Processor
{
    private $consumer;

    public function __construct(SerializedEnvelopeConsumer $consumer)
    {
        $this->consumer = $consumer;
    }

    public function process(Message $message, Context $context)
    {
        try {
            $this->consumer->consume($message->getBody());

            $result = self::ACK;
        } catch (InvalidMessageException $e) {
            $result = self::REJECT; // Reject invalid messages.
        } catch (Throwable $e) {
            $result = self::REQUEUE; // Do not loose messages when problem occurs e.g. for Redis transport.
        }

        return $result;
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace Enqueue\SimpleBus;
6
7			use Interop\Queue\Context;
8			use Interop\Queue\Exception\InvalidMessageException;
9			use Interop\Queue\Message;
10			use Interop\Queue\Processor;
11			use SimpleBus\Asynchronous\Consumer\SerializedEnvelopeConsumer;
12			use Throwable;
13
14			final class SimpleBusProcessor implements Processor
15			{
16			private $consumer;
17
18			public function __construct(SerializedEnvelopeConsumer $consumer)
19			{
20			$this->consumer = $consumer;
21			}
22
23			public function process(Message $message, Context $context)
24			{
25			try {
26			$this->consumer->consume($message->getBody());
27
28			$result = self::ACK;
29			} catch (InvalidMessageException $e) {
30			$result = self::REJECT; // Reject invalid messages.
31			} catch (Throwable $e) {
32			$result = self::REQUEUE; // Do not loose messages when problem occurs e.g. for Redis transport.
33			}
34
35			return $result;
36			}
37			}
38

damax-solutions / enqueue-simple-bus-queue-interop

SimpleBusProcessor::process() A last analyzed 2019-02-16 20:45 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

SimpleBusProcessor::process() A
last analyzed 2019-02-16 20:45 UTC