FM / Connectors

/var/www/flurhymez/vendor/laravel/framework/src/Illuminate/Queue/Connectors/

/var/www/flurhymez/vendor/laravel/framework/src/Illuminate/Queue/Connectors

Name	Size	Mode	Actions
BeanstalkdConnector.php	1049	0755	edit dl rm
ConnectorInterface.php	263	0755	edit dl rm
DatabaseConnector.php	1088	0644	edit dl rm
NullConnector.php	358	0644	edit dl rm
RedisConnector.php	1222	0644	edit dl rm
SqsConnector.php	1219	0755	edit dl rm
SyncConnector.php	358	0755	edit dl rm

Edit: /var/www/flurhymez/vendor/laravel/framework/src/Illuminate/Queue/Connectors/RedisConnector.php (1222B)

<?php

namespace Illuminate\Queue\Connectors;

use Illuminate\Contracts\Redis\Factory as Redis;
use Illuminate\Queue\RedisQueue;

class RedisConnector implements ConnectorInterface
{
    /**
     * The Redis database instance.
     *
     * @var \Illuminate\Contracts\Redis\Factory
     */
    protected $redis;

/**
     * The connection name.
     *
     * @var string
     */
    protected $connection;

/**
     * Create a new Redis queue connector instance.
     *
     * @param  \Illuminate\Contracts\Redis\Factory  $redis
     * @param  string|null  $connection
     * @return void
     */
    public function __construct(Redis $redis, $connection = null)
    {
        $this->redis = $redis;
        $this->connection = $connection;
    }

/**
     * Establish a queue connection.
     *
     * @param  array  $config
     * @return \Illuminate\Contracts\Queue\Queue
     */
    public function connect(array $config)
    {
        return new RedisQueue(
            $this->redis, $config['queue'],
            $config['connection'] ?? $this->connection,
            $config['retry_after'] ?? 60,
            $config['block_for'] ?? null,
            $config['after_commit'] ?? null
        );
    }
}

redis = $redis; $this->connection = $connection; } /** * Establish a queue connection. * * @param array $config * @return \Illuminate\Contracts\Queue\Queue */ public function connect(array $config) { return new RedisQueue( $this->redis, $config['queue'], $config['connection'] ?? $this->connection, $config['retry_after'] ?? 60, $config['block_for'] ?? null, $config['after_commit'] ?? null ); } }