summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorEvan Prodromou <evan@controlyourself.ca>2009-07-21 12:50:32 -0700
committerEvan Prodromou <evan@controlyourself.ca>2009-07-21 12:50:32 -0700
commitde987a9e63f38a3752491032d7a21759f2cc7560 (patch)
tree14204100037a59eaddc6b744ef089b91b0f72ea9
parent84fb84693994ba05a642d105a57227df7b412466 (diff)
update dbqueuemanager to respect handler timeout values
-rw-r--r--lib/dbqueuemanager.php3
1 files changed, 2 insertions, 1 deletions
diff --git a/lib/dbqueuemanager.php b/lib/dbqueuemanager.php
index 6e7172de0..a37a8ffdf 100644
--- a/lib/dbqueuemanager.php
+++ b/lib/dbqueuemanager.php
@@ -55,7 +55,8 @@ class DBQueueManager extends QueueManager
{
while (true) {
$this->_log(LOG_DEBUG, 'Checking for notices...');
- $notice = $this->_nextItem($queue, null);
+ $timeout = $handler->timeout();
+ $notice = $this->_nextItem($queue, $timeout);
if (empty($notice)) {
$this->_log(LOG_DEBUG, 'No notices waiting; idling.');
// Nothing in the queue. Do you