PSB\Core\EndpointInstance

Complexity

Total Complexity

6

Size/Duplication

Total Lines	60
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	send()	0	4	1
A	sendLocal()	0	4	1
A	publish()	0	4	1
A	subscribe()	0	4	1
A	unsubscribe()	0	4	1

<?php
namespace PSB\Core;


class EndpointInstance implements EndpointInstanceInterface
{
    /**
     * @var BusContextInterface
     */
    private $busContext;

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

    /**
     * @param object           $message
     * @param SendOptions|null $options
     */
    public function send($message, SendOptions $options = null)
    {
        $this->busContext->send($message, $options);
    }

    /**
     * @param object           $message
     * @param SendOptions|null $options
     */
    public function sendLocal($message, SendOptions $options = null)
    {
        $this->busContext->sendLocal($message, $options);
    }

    /**
     * @param object              $message
     * @param PublishOptions|null $options
     */
    public function publish($message, PublishOptions $options = null)
    {
        $this->busContext->publish($message, $options);
    }

    /**
     * @param string                $eventFqcn
     * @param SubscribeOptions|null $options
     */
    public function subscribe($eventFqcn, SubscribeOptions $options = null)
    {
        $this->busContext->subscribe($eventFqcn, $options);
    }

    /**
     * @param string                  $eventFqcn
     * @param UnsubscribeOptions|null $options
     */
    public function unsubscribe($eventFqcn, UnsubscribeOptions $options = null)
    {
        $this->busContext->unsubscribe($eventFqcn, $options);
    }
}