SwooleTW\Http\Task\Connectors\SwooleTaskConnector

Complexity

Total Complexity

2

Size/Duplication

Total Lines	31
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	connect()	0	3	1

<?php

namespace SwooleTW\Http\Task\Connectors;

use Illuminate\Queue\Connectors\ConnectorInterface;
use SwooleTW\Http\Helpers\FW;
use SwooleTW\Http\Task\QueueFactory;

/**
 * Class SwooleTaskConnector
 */
class SwooleTaskConnector implements ConnectorInterface
{
    /**
     * Swoole Server Instance
     *
     * @var \Swoole\Http\Server
     */
    protected $swoole;

    /**
     * Create a new Swoole Async task connector instance.
     *
     * @param  \Swoole\Http\Server $swoole
     *
     * @return void
     */
    public function __construct($swoole)
    {
        $this->swoole = $swoole;
    }

    /**
     * Establish a queue connection.
     *
     * @param  array $config
     *
     * @return \Illuminate\Contracts\Queue\Queue
     */
    public function connect(array $config)
    {
        return QueueFactory::make($this->swoole, FW::version());
    }
}