[PLUGINS] Added DBQueue plugin

This commit is contained in:
Miguel Dantas
2019-08-31 23:53:01 +01:00
committed by Hugo Sales
parent 4644f6e96b
commit 544f13c52a
5 changed files with 78 additions and 12 deletions

View File

@@ -59,7 +59,6 @@ abstract class QueueManager extends IoManager
if (empty(self::$qm)) {
if (Event::handle('StartNewQueueManager', array(&self::$qm))) {
$enabled = common_config('queue', 'enabled');
$type = common_config('queue', 'subsystem');
@@ -68,9 +67,6 @@ abstract class QueueManager extends IoManager
self::$qm = new UnQueueManager();
} else {
switch ($type) {
case 'db':
self::$qm = new DBQueueManager();
break;
default:
throw new ServerException("No queue manager class for type '$type'");
}