Freyo\LaravelQueueCMQ\Queue\Connectors\CMQConnector

Complexity

Total Complexity

1

Size/Duplication

Total Lines	26
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	3
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
A	connect()	0	15	1

<?php

namespace Freyo\LaravelQueueCMQ\Queue\Connectors;

use Freyo\LaravelQueueCMQ\Queue\CMQQueue;
use Freyo\LaravelQueueCMQ\Queue\Driver\Account;
use Illuminate\Queue\Connectors\ConnectorInterface;
use Illuminate\Support\Arr;

class CMQConnector implements ConnectorInterface
{
    /**
     * Establish a queue connection.
     *
     * @param array $config
     *
     * @throws \ReflectionException
     *
     * @return \Illuminate\Contracts\Queue\Queue
     */
    public function connect(array $config)
    {
        $queue = new Account(
            Arr::get($config, 'options.queue.host'),
            $config['secret_id'],
            $config['secret_key']
        );

        $topic = new Account(
            Arr::get($config, 'options.topic.host'),
            $config['secret_id'],
            $config['secret_key']
        );

        return new CMQQueue($queue, $topic, $config);
    }
}