PSB\Core\Transport\RabbitMq\RabbitMqSubscriptionManager

Complexity

Total Complexity

3

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	subscribe()	0	4	1
A	unsubscribe()	0	4	1

<?php
namespace PSB\Core\Transport\RabbitMq;


use PSB\Core\Transport\SubscriptionManagerInterface;

class RabbitMqSubscriptionManager implements SubscriptionManagerInterface
{
    /**
     * @var BrokerModel
     */
    private $brokerModel;

    /**
     * @var RoutingTopology
     */
    private $routingTopology;

    /**
     * @var string
     */
    private $localQueue;

    /**
     * @param BrokerModel     $brokerModel
     * @param RoutingTopology $routingTopology
     * @param string          $localQueue
     */
    public function __construct(BrokerModel $brokerModel, RoutingTopology $routingTopology, $localQueue)
    {
        $this->brokerModel = $brokerModel;
        $this->routingTopology = $routingTopology;
        $this->localQueue = $localQueue;
    }

    /**
     * @param string $eventFqcn
     */
    public function subscribe($eventFqcn)
    {
        $this->routingTopology->setupSubscription($this->brokerModel, $eventFqcn, $this->localQueue);
    }

    /**
     * @param string $eventFqcn
     */
    public function unsubscribe($eventFqcn)
    {
        $this->routingTopology->tearDownSubscription($this->brokerModel, $eventFqcn, $this->localQueue);
    }
}