Subversion-Projekte lars-tiefland.laravel_shop

<?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

        );

    }

}