Freyo\LaravelQueueRocketMQ\Queue\Connectors\RocketMQConnector

Complexity

Total Complexity

1

Size/Duplication

Total Lines	18
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

1 Method

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

<?php

namespace Freyo\LaravelQueueRocketMQ\Queue\Connectors;

use Freyo\LaravelQueueRocketMQ\Queue\RocketMQQueue;
use Illuminate\Queue\Connectors\ConnectorInterface;
use MQ\MQClient;

class RocketMQConnector implements ConnectorInterface
{
    /**
     * Establish a queue connection.
     *
     * @param array $config
     *
     * @throws \ReflectionException
     *
     * @return \Illuminate\Contracts\Queue\Queue
     */
    public function connect(array $config)
    {
        $client = new MQClient(
            $config['endpoint'], $config['access_id'], $config['access_key']
        );

        return new RocketMQQueue($client, $config);
    }
}