CMQConnector::connect()   A
last analyzed

Complexity

Conditions 1
Paths 1

Size

Total Lines 15
Code Lines 9

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 0
CRAP Score 2

Importance

Changes 2
Bugs 0 Features 0
Metric Value
cc 1
eloc 9
c 2
b 0
f 0
nc 1
nop 1
dl 0
loc 15
ccs 0
cts 13
cp 0
crap 2
rs 9.9666
1
<?php
2
3
namespace Freyo\LaravelQueueCMQ\Queue\Connectors;
4
5
use Freyo\LaravelQueueCMQ\Queue\CMQQueue;
6
use Freyo\LaravelQueueCMQ\Queue\Driver\Account;
7
use Illuminate\Queue\Connectors\ConnectorInterface;
8
use Illuminate\Support\Arr;
9
10
class CMQConnector implements ConnectorInterface
11
{
12
    /**
13
     * Establish a queue connection.
14
     *
15
     * @param array $config
16
     *
17
     * @throws \ReflectionException
18
     *
19
     * @return \Illuminate\Contracts\Queue\Queue
20
     */
21
    public function connect(array $config)
22
    {
23
        $queue = new Account(
24
            Arr::get($config, 'options.queue.host'),
25
            $config['secret_id'],
26
            $config['secret_key']
27
        );
28
29
        $topic = new Account(
30
            Arr::get($config, 'options.topic.host'),
31
            $config['secret_id'],
32
            $config['secret_key']
33
        );
34
35
        return new CMQQueue($queue, $topic, $config);
36
    }
37
}
38