Merge pull request #139 from vmiguellima/set-correct-queue-name

Set correct queue name from sqs job event
brefphp · Nov 23, 2023 · bc1a5ae · bc1a5ae
2 parents fa94fa8 + 9f73d61
commit bc1a5ae
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 10 deletions.
diff --git a/composer.json b/composer.json
@@ -13,7 +13,7 @@
     "require": {
         "php": "^8.0",
         "aws/aws-sdk-php": "^3.222",
-        "bref/bref": "^2.0",
+        "bref/bref": "^2.1.8",
         "illuminate/container": "^8.0 || ^9.0 || ^10.0",
         "illuminate/contracts": "^8.0 || ^9.0 || ^10.0",
         "illuminate/http": "^8.0 || ^9.0 || ^10.0",

diff --git a/src/Queue/QueueHandler.php b/src/Queue/QueueHandler.php
@@ -37,13 +37,6 @@ class QueueHandler extends SqsHandler
      */
     protected const JOB_TIMEOUT_SAFETY_MARGIN = 1.0;
 
-    /**
-     * The name of the SQS queue.
-     *
-     * @var string
-     */
-    protected string $queueName;
-
     /**
      * Creates a new SQS queue handler instance.
      *
@@ -66,7 +59,6 @@ public function __construct(
             throw new RuntimeException('Default queue connection is not a SQS connection');
         }
 
-        $this->queueName = $queue->getQueue(null);
         $this->sqs = $queue->getSqs();
     }
 
@@ -124,7 +116,7 @@ protected function marshalJob(SqsRecord $sqsRecord): SqsJob
             $this->sqs,
             $message,
             $this->connection,
-            $this->queueName,
+            $sqsRecord->getQueueName(),
         );
     }