[10.x] Replace QueueUrl with Endpoint

Author: danielsimkus

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'],
         ]);
     }
 

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),
             ]);
         });
     }