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/BeanstalkdConnector.php (1049B)

<?php

namespace Illuminate\Queue\Connectors;

use Illuminate\Queue\BeanstalkdQueue;
use Pheanstalk\Connection;
use Pheanstalk\Pheanstalk;

class BeanstalkdConnector implements ConnectorInterface
{
    /**
     * Establish a queue connection.
     *
     * @param  array  $config
     * @return \Illuminate\Contracts\Queue\Queue
     */
    public function connect(array $config)
    {
        return new BeanstalkdQueue(
            $this->pheanstalk($config),
            $config['queue'],
            $config['retry_after'] ?? Pheanstalk::DEFAULT_TTR,
            $config['block_for'] ?? 0,
            $config['after_commit'] ?? null
        );
    }

/**
     * Create a Pheanstalk instance.
     *
     * @param  array  $config
     * @return \Pheanstalk\Pheanstalk
     */
    protected function pheanstalk(array $config)
    {
        return Pheanstalk::create(
            $config['host'],
            $config['port'] ?? Pheanstalk::DEFAULT_PORT,
            $config['timeout'] ?? Connection::DEFAULT_CONNECT_TIMEOUT
        );
    }
}

pheanstalk($config), $config['queue'], $config['retry_after'] ?? Pheanstalk::DEFAULT_TTR, $config['block_for'] ?? 0, $config['after_commit'] ?? null ); } /** * Create a Pheanstalk instance. * * @param array $config * @return \Pheanstalk\Pheanstalk */ protected function pheanstalk(array $config) { return Pheanstalk::create( $config['host'], $config['port'] ?? Pheanstalk::DEFAULT_PORT, $config['timeout'] ?? Connection::DEFAULT_CONNECT_TIMEOUT ); } }