Skip to content

Disable sleep while queue items available #1250

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 15 commits into from
May 17, 2022
Merged

Disable sleep while queue items available #1250

Changes from all commits
Commits
Show all changes
15 commits
Select commit Hold shift + click to select a range
ce454a7
Merge pull request #1 from mordilion/hotfix/wait-between-subsciption-…
mordilion Apr 21, 2021
f011768
Merge branch 'php-enqueue:master' into master
mordilion Sep 29, 2021
f52be4b
just work on the next message based on priority and published_at
Sep 30, 2021
b313429
add logic to walk through the different queues after each message
Oct 7, 2021
1f00e43
small changes reagrding naming
Oct 7, 2021
d9af231
micro select for each queue
Oct 7, 2021
dd422aa
Merge branch 'php-enqueue:master' into master
mordilion Nov 8, 2021
c63705d
Merge branch 'master' into hotfix/work-on-prioritzed-job-list
Nov 8, 2021
85956da
Merge branch 'php-enqueue:master' into master
mordilion Dec 20, 2021
876c6c9
Merge branch 'master' into hotfix/work-on-prioritzed-job-list
Dec 20, 2021
6260028
if no queue was consumed, then wait the polling interval. Otherweise …
Jan 10, 2022
4b0d923
Merge branch 'php-enqueue:master' into master
mordilion Mar 1, 2022
01cc96e
Merge branch 'master' into hotfix/work-on-prioritzed-job-list
Mar 1, 2022
dedfcc7
Merge branch 'php-enqueue:master' into master
mordilion May 17, 2022
2a2471e
Merge branch 'master' into disable-sleep-while-queue-items-available
May 17, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 8 additions & 2 deletions pkg/dbal/DbalSubscriptionConsumer.php
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -95,17 +95,21 @@ public function consume(int $timeout = 0): void
$redeliveryDelay = $this->getRedeliveryDelay() / 1000; // milliseconds to seconds

$currentQueueNames = [];
$queueConsumed = false;
while (true) {
if (empty($currentQueueNames)) {
$currentQueueNames = $queueNames;
$queueConsumed = false;
}

$this->removeExpiredMessages();
$this->redeliverMessages();

if ($message = $this->fetchMessage($currentQueueNames, $redeliveryDelay)) {
$queueConsumed = true;

/**
* @var DbalConsumer
* @var DbalConsumer $consumer
* @var callable $callback
*/
[$consumer, $callback] = $this->subscribers[$message->getQueue()];
Expand All @@ -118,7 +122,9 @@ public function consume(int $timeout = 0): void
} else {
$currentQueueNames = [];

usleep($this->getPollingInterval() * 1000);
if (!$queueConsumed) {
usleep($this->getPollingInterval() * 1000);
}
}

if ($timeout && microtime(true) >= $now + $timeout) {
Expand Down