Completed
Push — master ( ad9f01...c2c3ec )
by frey
15s
created

CMQConnector::connect()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 15
Code Lines 9

Duplication

Lines 0
Ratio 0 %

Importance

Changes 0
Metric Value
cc 1
eloc 9
nc 1
nop 1
dl 0
loc 15
rs 9.9666
c 0
b 0
f 0
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
     * @return \Illuminate\Contracts\Queue\Queue
18
     */
19
    public function connect(array $config)
20
    {
21
        $queue = new Account(
22
            Arr::get($config, 'options.queue.host'),
23
            $config['secret_id'],
24
            $config['secret_key']
25
        );
26
27
        $topic = new Account(
28
            Arr::get($config, 'options.topic.host'),
29
            $config['secret_id'],
30
            $config['secret_key']
31
        );
32
33
        return new CMQQueue($queue, $topic, $config);
34
    }
35
}
36