🚧 wip

Author: palpalani

src/Sqs/Queue.php

@@ -54,7 +54,7 @@ private function getClass($queue = null): string
         $queueId = explode('/', $queue);
         $queueId = array_pop($queueId);
 
-        return (array_key_exists($queueId, Config::get('sqs-queue-reader.handlers')))
+        return (\array_key_exists($queueId, Config::get('sqs-queue-reader.handlers')))
             ? Config::get('sqs-queue-reader.handlers')[$queueId]['class']
             : Config::get('sqs-queue-reader.default-handler')['class'];
     }
@@ -74,7 +74,7 @@ public function pop($queue = null)
         $queueId = explode('/', $queue);
         $queueId = array_pop($queueId);
 
-        $count = (array_key_exists($queueId, Config::get('sqs-queue-reader.handlers')))
+        $count = (\array_key_exists($queueId, Config::get('sqs-queue-reader.handlers')))
             ? Config::get('sqs-queue-reader.handlers')[$queueId]['count']
             : Config::get('sqs-queue-reader.default-handler')['count'];
 
@@ -87,7 +87,7 @@ public function pop($queue = null)
             ]);
 
             if (isset($response['Messages']) && count($response['Messages']) > 0) {
-                $class = (array_key_exists($queueId, $this->container['config']->get('sqs-queue-reader.handlers')))
+                $class = (\array_key_exists($queueId, $this->container['config']->get('sqs-queue-reader.handlers')))
                     ? $this->container['config']->get('sqs-queue-reader.handlers')[$queueId]['class']
                     : $this->container['config']->get('sqs-queue-reader.default-handler')['class'];
 

src/SqsQueueReaderServiceProvider.php

@@ -25,13 +25,13 @@ public function boot(): void
 
             Queue::after(function (JobProcessed $event) {
                 $connections = Config::get('queue.connections');
-                if (in_array($event->connectionName, array_keys($connections), true)) {
+                if (\in_array($event->connectionName, array_keys($connections), true)) {
                     $queue = $event->job->getQueue();
 
                     $queueId = explode('/', $queue);
                     $queueId = array_pop($queueId);
 
-                    $count = (array_key_exists($queueId, Config::get('sqs-queue-reader.handlers')))
+                    $count = (\array_key_exists($queueId, Config::get('sqs-queue-reader.handlers')))
                         ? Config::get('sqs-queue-reader.handlers')[$queueId]['count']
                         : Config::get('sqs-queue-reader.default-handler')['count'];