diff options
| author | Evan Prodromou <evan@controlyourself.ca> | 2009-07-21 12:50:32 -0700 |
|---|---|---|
| committer | Evan Prodromou <evan@controlyourself.ca> | 2009-07-21 12:52:55 -0700 |
| commit | 6467351e32d2fa3a838556725fbdaccfa907969d (patch) | |
| tree | e70150bb90143bf45803dba620e7b49dc03d41a2 | |
| parent | eb5679b0297738649b982dfb66af5021bb03be19 (diff) | |
update dbqueuemanager to respect handler timeout values
| -rw-r--r-- | lib/dbqueuemanager.php | 3 |
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 |