Added debug messages

Author: palPalani

README.md

@@ -59,7 +59,7 @@ Add sqs-json connection to your config/queue.php, eg:
     ]
 ```
 
-In your .env file, choose sqs-plain as your new default queue driver:
+In your .env file, choose sqs-json as your new default queue driver:
 
 ```
 QUEUE_DRIVER=sqs-json

config/sqs-queue-reader.php

@@ -9,7 +9,7 @@
      * Separate queue handle with corresponding queue name as key.
      */
     'handlers' => [
-        //'stripe-webhooks' => App\Jobs\SqsHandler::class,
+        'st-webhooks' => App\Jobs\SqsHandler::class,
     ],
 
     'default-handler' => App\Jobs\SqsHandler::class

src/Jobs/DispatcherJob.php

@@ -65,4 +65,9 @@ public function isPlain()
     {
         return $this->plain;
     }
+
+    public function __invoke()
+    {
+        $this->getPayload();
+    }
 }

src/Sqs/Queue.php

@@ -5,6 +5,7 @@
 use Illuminate\Queue\Jobs\SqsJob;
 use Illuminate\Queue\SqsQueue;
 use Illuminate\Support\Facades\Config;
+use Illuminate\Support\Facades\Log;
 use palPalani\SqsQueueReader\Jobs\DispatcherJob;
 
 /**
@@ -28,7 +29,7 @@ protected function createPayload($job, $data = '', $queue = null)
         }
 
         $handlerJob = $this->getClass($queue) . '@handle';
-
+        Log::debug('$job->isPlain()====', [$job->isPlain()]);
         return $job->isPlain() ? json_encode($job->getPayload()) : json_encode(['job' => $handlerJob, 'data' => $job->getPayload()]);
     }
 
@@ -62,8 +63,12 @@ public function pop($queue = null)
         $response = $this->sqs->receiveMessage([
             'QueueUrl' => $queue,
             'AttributeNames' => ['ApproximateReceiveCount'],
+            'MaxNumberOfMessages' => 1,
+            'MessageAttributeNames' => ['All'],
         ]);
 
+        Log::debug('MessageAttributeNames=', [$response]);
+
         if (isset($response['Messages']) && count($response['Messages']) > 0) {
             $queueId = explode('/', $queue);
             $queueId = array_pop($queueId);

src/SqsQueueReaderServiceProvider.php

@@ -24,7 +24,7 @@ public function boot()
 
     public function register()
     {
-        $this->mergeConfigFrom(__DIR__ . '/../config/sqs-queue-reader.php', 'laravel-sqs-queue-json-reader');
+        $this->mergeConfigFrom(__DIR__ . '/../config/sqs-queue-reader.php', 'sqs-queue-reader');
 
         $this->app->booted(function () {
             $this->app['queue']->extend('sqs-json', static function () {