From: Brion Vibber Date: Tue, 16 Feb 2010 17:25:09 +0000 (-0800) Subject: Merge branch 'testing' into 0.9.x X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=d5cbfe8071d56438cfa168dc3db56a959317eae0;p=quix0rs-gnu-social.git Merge branch 'testing' into 0.9.x Conflicts: lib/iomaster.php --- d5cbfe8071d56438cfa168dc3db56a959317eae0 diff --cc lib/queuemanager.php index 64bb52e106,8f8c8f133f..710829e497 --- a/lib/queuemanager.php +++ b/lib/queuemanager.php @@@ -212,15 -213,13 +213,15 @@@ abstract class QueueManager extends IoM { if (isset($this->handlers[$queue])) { $class = $this->handlers[$queue]; - if (class_exists($class)) { + if(is_object($class)) { + return $class; + } else if (class_exists($class)) { return new $class(); } else { - common_log(LOG_ERR, "Nonexistent handler class '$class' for queue '$queue'"); + $this->_log(LOG_ERR, "Nonexistent handler class '$class' for queue '$queue'"); } } else { - common_log(LOG_ERR, "Requested handler for unkown queue '$queue'"); + $this->_log(LOG_ERR, "Requested handler for unkown queue '$queue'"); } return null; } @@@ -275,10 -283,10 +285,10 @@@ * Only registered transports will be reliably picked up! * * @param string $transport - * @param string $class + * @param string $class class name or object instance * @param string $group */ - public function connect($transport, $class, $group='queuedaemon') + public function connect($transport, $class, $group='main') { $this->handlers[$transport] = $class; $this->groups[$group][$transport] = $class;