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/DatabaseConnector.php (1088B)

<?php

namespace Illuminate\Queue\Connectors;

use Illuminate\Database\ConnectionResolverInterface;
use Illuminate\Queue\DatabaseQueue;

class DatabaseConnector implements ConnectorInterface
{
    /**
     * Database connections.
     *
     * @var \Illuminate\Database\ConnectionResolverInterface
     */
    protected $connections;

/**
     * Create a new connector instance.
     *
     * @param  \Illuminate\Database\ConnectionResolverInterface  $connections
     * @return void
     */
    public function __construct(ConnectionResolverInterface $connections)
    {
        $this->connections = $connections;
    }

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

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