diff --git a/composer.json b/composer.json index dac49e5946c..4dadb070dfe 100644 --- a/composer.json +++ b/composer.json @@ -94,7 +94,7 @@ "require-dev": { "ext-gmp": "*", "ably/ably-php": "^1.0", - "aws/aws-sdk-php": "^3.235.5", + "aws/aws-sdk-php": "3.288.1", "doctrine/dbal": "^3.5.1", "fakerphp/faker": "^1.21", "guzzlehttp/guzzle": "^7.5", diff --git a/src/Illuminate/Queue/Jobs/SqsJob.php b/src/Illuminate/Queue/Jobs/SqsJob.php index 87b722e207b..d298412bd04 100755 --- a/src/Illuminate/Queue/Jobs/SqsJob.php +++ b/src/Illuminate/Queue/Jobs/SqsJob.php @@ -52,7 +52,7 @@ public function release($delay = 0) parent::release($delay); $this->sqs->changeMessageVisibility([ - 'QueueUrl' => $this->queue, + 'Endpoint' => $this->queue, 'ReceiptHandle' => $this->job['ReceiptHandle'], 'VisibilityTimeout' => $delay, ]); @@ -68,7 +68,7 @@ public function delete() parent::delete(); $this->sqs->deleteMessage([ - 'QueueUrl' => $this->queue, 'ReceiptHandle' => $this->job['ReceiptHandle'], + 'Endpoint' => $this->queue, 'ReceiptHandle' => $this->job['ReceiptHandle'], ]); } diff --git a/src/Illuminate/Queue/SqsQueue.php b/src/Illuminate/Queue/SqsQueue.php index d4ca1d99394..faa52195419 100755 --- a/src/Illuminate/Queue/SqsQueue.php +++ b/src/Illuminate/Queue/SqsQueue.php @@ -70,7 +70,7 @@ public function __construct(SqsClient $sqs, public function size($queue = null) { $response = $this->sqs->getQueueAttributes([ - 'QueueUrl' => $this->getQueue($queue), + 'Endpoint' => $this->getQueue($queue), 'AttributeNames' => ['ApproximateNumberOfMessages'], ]); @@ -111,7 +111,7 @@ function ($payload, $queue) { public function pushRaw($payload, $queue = null, array $options = []) { return $this->sqs->sendMessage([ - 'QueueUrl' => $this->getQueue($queue), 'MessageBody' => $payload, + 'Endpoint' => $this->getQueue($queue), 'MessageBody' => $payload, ])->get('MessageId'); } @@ -133,7 +133,7 @@ public function later($delay, $job, $data = '', $queue = null) $delay, function ($payload, $queue, $delay) { return $this->sqs->sendMessage([ - 'QueueUrl' => $this->getQueue($queue), + 'Endpoint' => $this->getQueue($queue), 'MessageBody' => $payload, 'DelaySeconds' => $this->secondsUntil($delay), ])->get('MessageId'); @@ -169,7 +169,7 @@ public function bulk($jobs, $data = '', $queue = null) public function pop($queue = null) { $response = $this->sqs->receiveMessage([ - 'QueueUrl' => $queue = $this->getQueue($queue), + 'Endpoint' => $queue = $this->getQueue($queue), 'AttributeNames' => ['ApproximateReceiveCount'], ]); @@ -191,7 +191,7 @@ public function clear($queue) { return tap($this->size($queue), function () use ($queue) { $this->sqs->purgeQueue([ - 'QueueUrl' => $this->getQueue($queue), + 'Endpoint' => $this->getQueue($queue), ]); }); }