Method __construct

php/src/Queue.php:64–80

* Create a new Queue instance. * * @param string $name The name of the queue * @param array{ * prefix?: string, * connection?: RedisConnection|array |string * } $opts Queue options */

(string $name, array $opts = [])

     * } $opts Queue options
     */
    public function __construct(string $name, array $opts = [])
    {
        $this->name = $name;
        $this->prefix = $opts['prefix'] ?? 'bull';

        // Handle connection option
        $connection = $opts['connection'] ?? [];
        if ($connection instanceof RedisConnection) {
            $this->connection = $connection;
        } else {
            $this->connection = new RedisConnection($connection);
            $this->ownsConnection = true;
        }

        $this->keys = new QueueKeys($this->prefix);
        $this->scripts = new Scripts($this->prefix, $this->name, $this->connection);
    }

    /**
     * Get the Redis connection.