Bernard\EventListener\FailureSubscriber

Complexity

Total Complexity

3

Size/Duplication

Total Lines	36
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

52.94%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	onReject()	0	7	1
A	getSubscribedEvents()	0	6	1

<?php

namespace Bernard\EventListener;

use Bernard\Event\RejectEnvelopeEvent;
use Bernard\Producer;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;

class FailureSubscriber implements EventSubscriberInterface
{
    protected $producer;
    protected $name;

    /**
     * @param Producer $producer
     * @param string   $name
     */
    public function __construct(Producer $producer, $name = 'failed')
    {
        $this->producer = $producer;
        $this->name = $name;
    }

    /**
     * @param RejectEnvelopeEvent $event
     */
    public function onReject(RejectEnvelopeEvent $event)
    {
        $envelope = $event->getEnvelope();
        $message = $envelope->getMessage();

        $this->producer->produce($message, $this->name);
    }

    /**
     * @return array
     */
    public static function getSubscribedEvents()
    {
        return [
            'bernard.reject' => ['onReject'],
        ];
    }
}