Softonic\AmqpConsumer\ServiceProvider::register()

Complexity

Conditions	1
Paths	1

Size

Total Lines

26

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2

Importance

Changes

0

<?php
    public function register()
    {
        $this->mergeConfigFrom(__DIR__ . '/../config/' . $this->packageName . '.php', $this->packageName);

        $this->app->bind(AmqpListener::class, function () {
            $amqpProperties  = config('amqp-consumer')['properties'];
            $messageHandlers = config('amqp-consumer')['message_handlers'];

            $routingKeys = array_unique(Arr::flatten($messageHandlers));

            $amqpProperties['routing'] = $routingKeys;

            return new AmqpListener(
                config('amqp-consumer')['queue'],
                $amqpProperties
            );
        });

        $this->app->bind(AmqpHandler::class, function () {
            return new AmqpHandler(
                config('amqp-consumer')['message_handlers']
            );
        });

        $this->commands([AmqpListener::class]);
    }
}