| 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 |