Файл: gapps/vendor/laravel/framework/src/Illuminate/Queue/Connectors/SqsConnector.php
Строк: 57
<?php
namespace IlluminateQueueConnectors;
use AwsSqsSqsClient;
use IlluminateSupportArr;
use IlluminateQueueSqsQueue;
class SqsConnector implements ConnectorInterface
{
/**
* Establish a queue connection.
*
* @param array $config
* @return IlluminateContractsQueueQueue
*/
public function connect(array $config)
{
$config = $this->getDefaultConfiguration($config);
if ($config['key'] && $config['secret']) {
$config['credentials'] = Arr::only($config, ['key', 'secret']);
}
return new SqsQueue(
new SqsClient($config), $config['queue'], Arr::get($config, 'prefix', '')
);
}
/**
* 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);
}
}