Burrow\Handler\ContinueOnExceptionHandler

Complexity

Total Complexity

5

Size/Duplication

Total Lines	54
Duplicated Lines	100 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	6	6	1
A	handle()	15	15	3
A	options()	4	4	1

<?php

namespace Burrow\Handler;

use Burrow\ConsumeOptions;
use Burrow\Exception\ConsumerException;
use Burrow\Message;
use Burrow\QueueHandler;
use Psr\Log\LoggerAwareInterface;
use Psr\Log\LoggerAwareTrait;
use Psr\Log\NullLogger;

class ContinueOnExceptionHandler implements QueueHandler, LoggerAwareInterface

This class seems to be duplicated in your project.

{
    use LoggerAwareTrait;

    /** @var QueueHandler */
    private $handler;

    /**
     * AckHandler constructor.
     *
     * @param QueueHandler $handler
     */
    public function __construct(QueueHandler $handler)
    {
        $this->handler = $handler;

        $this->logger = new NullLogger();
    }

    /**
     * Handle a message.
     *
     * @param Message $message
     *
     * @return bool
     */
    public function handle(Message $message)
    {
        // Beware of infinite loop!
        try {
            $this->handler->handle($message);
        } catch (\Exception $e) {
            $this->logger->error($e);

            if ($e instanceof ConsumerException) {
                return false;
            }
        }

        return self::CONTINUE_CONSUMING;
    }

    /**
     * Modify and return the options for consumption.
     *
     * @param ConsumeOptions $options
     *
     * @return ConsumeOptions
     */
    public function options(ConsumeOptions $options)
    {
        return $this->handler->options($options);
    }
}