NeedleProject\LaravelRabbitMq\Processor\AbstractMessageProcessor

Complexity

Total Complexity

4

Size/Duplication

Total Lines	53
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
	processMessage()	0	1	?
A	consume()	0	25	3
A	getProcessedMessages()	0	4	1

<?php
namespace NeedleProject\LaravelRabbitMq\Processor;

use PhpAmqpLib\Message\AMQPMessage;
use Psr\Log\LoggerAwareInterface;
use Psr\Log\LoggerAwareTrait;

/**
 * Class AbstractMessageProcessor
 *
 * @package NeedleProject\LaravelRabbitMq\Processor
 * @author  Adrian tilita <adrian@tilita.ro>
 */
abstract class AbstractMessageProcessor implements MessageProcessorInterface, LoggerAwareInterface
{
    use LoggerAwareTrait;

    /**
     * @var int
     */
    private $messageCount = 0;

    /**
     * {@inheritdoc}
     * @param AMQPMessage $message
     */
    public function consume(AMQPMessage $message)
    {
        $this->messageCount++;
        try {
            $response = $this->processMessage($message);
            if ($response === true) {
                $this->logger->debug(sprintf("Processed with success message %s", $message->getBody()));
                $message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']);
            } else {
                $this->logger->debug(sprintf("Did not processed with success message %s", $message->getBody()));
                $message->delivery_info['channel']->basic_nack($message->delivery_info['delivery_tag'], false, true);
            }
        } catch (\Exception $e) {
            $this->logger->error(
                sprintf(
                    "Could not process message, got %s from %s in %d for message: %s",
                    get_class($e) . '-' . $e->getMessage(),
                    (string)$e->getFile(),
                    (int)$e->getLine(),
                    (string)$message->getBody()
                )
            );
            $message->delivery_info['channel']->basic_nack($message->delivery_info['delivery_tag'], false, true);
        }
    }

    /**
     * @return int
     */
    public function getProcessedMessages(): int
    {
        return $this->messageCount;
    }

    /**
     * @param AMQPMessage $message
     * @return bool
     */
    abstract public function processMessage(AMQPMessage $message): bool;

function processMessage() does not seem to conform to the naming convention (^(?:is|has|should|may|supports)).

}