Skip to content

Commit

Permalink
Remove fallback value
Browse files Browse the repository at this point in the history
  • Loading branch information
vmiguellima committed Nov 14, 2023
1 parent 9ddd9fd commit 9f73d61
Showing 1 changed file with 1 addition and 9 deletions.
10 changes: 1 addition & 9 deletions src/Queue/QueueHandler.php
Original file line number Diff line number Diff line change
Expand Up @@ -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.
*
Expand All @@ -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();
}

Expand Down Expand Up @@ -124,7 +116,7 @@ protected function marshalJob(SqsRecord $sqsRecord): SqsJob
$this->sqs,
$message,
$this->connection,
$sqsRecord->getQueueName() ?? $this->queueName,
$sqsRecord->getQueueName(),
);
}

Expand Down

0 comments on commit 9f73d61

Please sign in to comment.