diff --git a/composer.json b/composer.json index a6a7d0c..fd1613f 100644 --- 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 index b21b365..999f245 100644 --- 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(), ); }