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/SqsConnector.php (1219B)

<?php

namespace Illuminate\Queue\Connectors;

use Aws\Sqs\SqsClient;
use Illuminate\Queue\SqsQueue;
use Illuminate\Support\Arr;

class SqsConnector implements ConnectorInterface
{
    /**
     * Establish a queue connection.
     *
     * @param  array  $config
     * @return \Illuminate\Contracts\Queue\Queue
     */
    public function connect(array $config)
    {
        $config = $this->getDefaultConfiguration($config);

if (! empty($config['key']) && ! empty($config['secret'])) {
            $config['credentials'] = Arr::only($config, ['key', 'secret', 'token']);
        }

return new SqsQueue(
            new SqsClient($config),
            $config['queue'],
            $config['prefix'] ?? '',
            $config['suffix'] ?? '',
            $config['after_commit'] ?? null
        );
    }

/**
     * Get the default configuration for SQS.
     *
     * @param  array  $config
     * @return array
     */
    protected function getDefaultConfiguration(array $config)
    {
        return array_merge([
            'version' => 'latest',
            'http' => [
                'timeout' => 60,
                'connect_timeout' => 60,
            ],
        ], $config);
    }
}

getDefaultConfiguration($config); if (! empty($config['key']) && ! empty($config['secret'])) { $config['credentials'] = Arr::only($config, ['key', 'secret', 'token']); } return new SqsQueue( new SqsClient($config), $config['queue'], $config['prefix'] ?? '', $config['suffix'] ?? '', $config['after_commit'] ?? null ); } /** * Get the default configuration for SQS. * * @param array $config * @return array */ protected function getDefaultConfiguration(array $config) { return array_merge([ 'version' => 'latest', 'http' => [ 'timeout' => 60, 'connect_timeout' => 60, ], ], $config); } }