- switch ($type) {
- case 'db':
- self::$qm = new DBQueueManager();
- break;
- case 'stomp':
- self::$qm = new StompQueueManager();
- break;
- default:
- throw new ServerException("No queue manager class for type '$type'");
+ if (!$enabled) {
+ // does everything immediately
+ self::$qm = new UnQueueManager();
+ } else {
+ switch ($type) {
+ case 'db':
+ self::$qm = new DBQueueManager();
+ break;
+ case 'stomp':
+ self::$qm = new StompQueueManager();
+ break;
+ default:
+ throw new ServerException("No queue manager class for type '$type'");
+ }