Skip to content

Commit

Permalink
Merge pull request #203 from yaroslav-pohil/fix-getting-default-queue
Browse files Browse the repository at this point in the history
Fix getting default queue settings
  • Loading branch information
freekmurze committed Nov 27, 2023
2 parents 012f66b + 5f3ad90 commit 15e216d
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 1 deletion.
2 changes: 1 addition & 1 deletion src/Checks/Checks/QueueCheck.php
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ public function onQueue(array|string $queue): self

public function getQueues(): array
{
return $this->onQueues ?? [$this->getDefaultQueue(config('queue.driver'))];
return $this->onQueues ?? [$this->getDefaultQueue(config('queue.default'))];
}

protected function getDefaultQueue($connection)
Expand Down
12 changes: 12 additions & 0 deletions tests/Checks/QueueCheckTest.php
Original file line number Diff line number Diff line change
Expand Up @@ -97,3 +97,15 @@
Queue::assertPushedOn('email', HealthQueueJob::class);
Queue::assertPushedOn('payment', HealthQueueJob::class);
});

it('can get default queue settings', function () {
// Set default queue connection
$queueConnection = uniqid('connection');
config()->set('queue.default', $queueConnection);

// Set default queue name
$queueName = uniqid('queue');
config()->set("queue.connections.{$queueConnection}.queue", $queueName);

expect($this->queueCheck->getQueues())->toBe([$queueName]);
});

0 comments on commit 15e216d

Please sign in to comment.