Add uuid

src/Sqs/Queue.php

@@ -6,6 +6,7 @@
 use Illuminate\Queue\SqsQueue;
 use Illuminate\Support\Facades\Config;
 use Illuminate\Support\Facades\Log;
+use Illuminate\Support\Str;
 use palPalani\SqsQueueReader\Jobs\DispatcherJob;
 
 /**
@@ -81,11 +82,8 @@ public function pop($queue = null)
 
             $response = $this->modifyPayload($response['Messages'], $class);
             Log::debug('New $responseV2==', [$response]);
-            if (preg_match('/(5\.[4-8]\..*)|(6\.[0-9]*\..*)|(7\.[0-9]*\..*)|(8\.[0-9]*\..*)/', $this->container->version())) {
-                return new SqsJob($this->container, $this->sqs, $response, $this->connectionName, $queue);
-            }
 
-            return new SqsJob($this->container, $this->sqs, $queue, $response);
+            return new SqsJob($this->container, $this->sqs, $response, $this->connectionName, $queue);
         }
     }
 
@@ -122,6 +120,7 @@ private function modifyPayload($payload, $class)
         }
 
         $body = [
+            'uuid' => (string) Str::uuid(),
             'job' => $class . '@handle',
             'data' => $body,
         ];

src/SqsQueueReaderServiceProvider.php

@@ -3,6 +3,7 @@
 namespace palPalani\SqsQueueReader;
 
 use Illuminate\Queue\Events\JobProcessed;
+use Illuminate\Support\Facades\Log;
 use Illuminate\Support\Facades\Queue;
 use Illuminate\Support\ServiceProvider;
 use palPalani\SqsQueueReader\Sqs\Connector;
@@ -17,6 +18,7 @@ public function boot(): void
             ], 'config');
 
             Queue::after(static function (JobProcessed $event) {
+                Log::debug('Job data==', [$event->job]);
                 $event->job->delete();
             });
         }