EndpointInstance::subscribe()   A
last analyzed

Complexity

Conditions 1
Paths 1

Size

Total Lines 4

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 3
CRAP Score 1

Importance

Changes 0
Metric Value
dl 0
loc 4
ccs 3
cts 3
cp 1
rs 10
c 0
b 0
f 0
cc 1
nc 1
nop 2
crap 1
1
<?php
2
namespace PSB\Core;
3
4
5
class EndpointInstance implements EndpointInstanceInterface
6
{
7
    /**
8
     * @var BusContextInterface
9
     */
10
    private $busContext;
11
12
    /**
13
     * @param BusContextInterface $busContext
14
     */
15 6
    public function __construct(BusContextInterface $busContext)
16
    {
17 6
        $this->busContext = $busContext;
18 6
    }
19
20
    /**
21
     * @param object           $message
22
     * @param SendOptions|null $options
23
     */
24 1
    public function send($message, SendOptions $options = null)
25
    {
26 1
        $this->busContext->send($message, $options);
27 1
    }
28
29
    /**
30
     * @param object           $message
31
     * @param SendOptions|null $options
32
     */
33 1
    public function sendLocal($message, SendOptions $options = null)
34
    {
35 1
        $this->busContext->sendLocal($message, $options);
36 1
    }
37
38
    /**
39
     * @param object              $message
40
     * @param PublishOptions|null $options
41
     */
42 1
    public function publish($message, PublishOptions $options = null)
43
    {
44 1
        $this->busContext->publish($message, $options);
45 1
    }
46
47
    /**
48
     * @param string                $eventFqcn
49
     * @param SubscribeOptions|null $options
50
     */
51 1
    public function subscribe($eventFqcn, SubscribeOptions $options = null)
52
    {
53 1
        $this->busContext->subscribe($eventFqcn, $options);
54 1
    }
55
56
    /**
57
     * @param string                  $eventFqcn
58
     * @param UnsubscribeOptions|null $options
59
     */
60 1
    public function unsubscribe($eventFqcn, UnsubscribeOptions $options = null)
61
    {
62 1
        $this->busContext->unsubscribe($eventFqcn, $options);
63 1
    }
64
}
65