Equip\Queue\Event

Complexity

Total Complexity

3

Size/Duplication

Total Lines	49
Duplicated Lines	36.73 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	2
Bugs	0	Features	2

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	acknowledge()	9	9	1
A	reject()	9	9	1

<?php

namespace Equip\Queue;

use Exception;
use League\Event\EmitterInterface;

class Event
{
    const QUEUE_ACKNOWLEDGE = 'queue.acknowledge';
    const QUEUE_REJECT = 'queue.reject';

    /**
     * @var EmitterInterface
     */
    private $emitter;

    /**
     * @param EmitterInterface $emitter
     */
    public function __construct(EmitterInterface $emitter)
    {
        $this->emitter = $emitter;
    }

    /**
     * Emits message acknowledgement events
     *
     * @param Message $message
     */
    public function acknowledge(Message $message)

This method seems to be duplicated in your project.

    {
        array_map(function ($name) use ($message) {
            $this->emitter->emit($name, $message);

The call to EmitterInterface::emit() has too many arguments starting with $message.

        }, [
            static::QUEUE_ACKNOWLEDGE,
            sprintf('%s.%s', static::QUEUE_ACKNOWLEDGE, $message->handler())
        ]);
    }

    /**
     * Emits message rejection events
     *
     * @param Message $message
     * @param Exception $exception
     */
    public function reject(Message $message, Exception $exception)

This method seems to be duplicated in your project.

    {
        array_map(function ($name) use ($message, $exception) {
            $this->emitter->emit($name, $message, $exception);

The call to EmitterInterface::emit() has too many arguments starting with $message.

        }, [
            static::QUEUE_REJECT,
            sprintf('%s.%s', static::QUEUE_REJECT, $message->handler())
        ]);
    }
}