Canvas\Providers\QueueProvider

Complexity

Total Complexity

1

Size/Duplication

Total Lines	19
Duplicated Lines	0 %

Test Coverage

Coverage

88.89%

Importance

Changes	3
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
A	register()	0	14	1

<?php

namespace Canvas\Providers;

use Phalcon\Di\ServiceProviderInterface;

The type Phalcon\Di\ServiceProviderInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Phalcon\DiInterface;

The type Phalcon\DiInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Phalcon\Queue\Beanstalk\Extended as Beanstalk;
use PhpAmqpLib\Connection\AMQPStreamConnection;
use function Canvas\Core\envValue;

class QueueProvider implements ServiceProviderInterface
{
    /**
     * @param DiInterface $container
     */
    public function register(DiInterface $container)
    {
        $container->setShared(
            'queue',
            function () {
                //Connect to the queue
                $queue = new AMQPStreamConnection(
                    envValue('RABBITMQ_HOST'),
                    envValue('RABBITMQ_PORT'),
                    envValue('RABBITMQ_DEFAULT_USER'),
                    envValue('RABBITMQ_DEFAULT_PASS')
                );

                return $queue;
            }
         );

        /*  $container->setShared(
             'queue',
             function () {
                 //Connect to the queue
                 $queue = new Beanstalk([
                     'host' => envValue('DATA_API_BEANSTALK_HOST', '127.0.0.1'),
                     'prefix' => envValue('DATA_API_BEANSTALK_PORT', 11300),
                 ]);
                 return $queue;
             }
         ); */
    }
}