Use SqsClient for delete bulk message

Author: palPalani

src/SqsQueueReaderServiceProvider.php

@@ -8,6 +8,8 @@
 use Illuminate\Support\Facades\Queue;
 use Illuminate\Support\ServiceProvider;
 use palPalani\SqsQueueReader\Sqs\Connector;
+use Aws\Sqs\SqsClient;
+use Aws\Exception\AwsException;
 
 class SqsQueueReaderServiceProvider extends ServiceProvider
 {
@@ -40,23 +42,40 @@ public function boot(): void
                         $batchIds = array_chunk($batchIds, 10);
                         Log::debug('Job array_chunk==', [$batchIds]);
 
+                        $client = new SqsClient([
+                            //'profile' => 'default',
+                            'region' => Config::get('queue.connections.sqs-json.region'),
+                            'version' => '2012-11-05'
+                        ]);
+
                         foreach ($batchIds as $batch) {
                             //Deletes up to ten messages from the specified queue.
+                            /*
                             $result = $event->job->deleteMessageBatch([
                                 'Entries' => $batch,
                                 'QueueUrl' => $queue,
                             ]);
+                            */
 
-                            if (isset($result['Failed'])) {
-                                $msg = '';
-                                foreach ($result['Failed'] as $failed) {
-                                    $msg .= sprintf("Deleting message failed, code = %s, id = %s, msg = %s, senderfault = %s", $failed['Code'], $failed['Id'], $failed['Message'], $failed['SenderFault']);
-                                }
-                                Log::error('Cannot delete some SQS messages: ', [$msg]);
+                            try {
+                                $result = $client->deleteMessageBatch([
+                                    'Entries' => $batch,
+                                    'QueueUrl' => $queue,
+                                ]);
 
-                                throw new \RuntimeException("Cannot delete some messages, consult log for more info!");
+                                if (isset($result['Failed'])) {
+                                    $msg = '';
+                                    foreach ($result['Failed'] as $failed) {
+                                        $msg .= sprintf("Deleting message failed, code = %s, id = %s, msg = %s, senderfault = %s", $failed['Code'], $failed['Id'], $failed['Message'], $failed['SenderFault']);
+                                    }
+                                    Log::error('Cannot delete some SQS messages: ', [$msg]);
+
+                                    throw new \RuntimeException("Cannot delete some messages, consult log for more info!");
+                                }
+                                Log::info('Message remove report:', [$result]);
+                            } catch (AwsException $e) {
+                                Log::error('AWS SQS client error:', [$e->getMessage()]);
                             }
-                            Log::info('Message remove report:', [$result]);
                         }
                     }
                 }