Total Complexity | 3 |
Total Lines | 23 |
Duplicated Lines | 0 % |
Coverage | 75% |
Changes | 0 |
1 | <?php |
||
13 | class RabbitMQFacade extends AbstractFacade |
||
14 | { |
||
15 | /** |
||
16 | * Initiate the exchanges and queues in RabbitMQ |
||
17 | * |
||
18 | * @api |
||
19 | */ |
||
20 | 2 | public function init(): void |
|
21 | { |
||
22 | 2 | $this->getFactory()->createBootstrapper()->boot(); |
|
23 | 2 | } |
|
24 | |||
25 | /** |
||
26 | * @throws \Xervice\RabbitMQ\Worker\Listener\ListenerException |
||
27 | */ |
||
28 | 2 | public function runWorker(): void |
|
29 | { |
||
30 | 2 | $this->getFactory()->createWorker()->runWorker(); |
|
31 | 2 | } |
|
32 | |||
33 | public function close(): void |
||
36 | } |
||
37 | } |
||
38 |