1 | import { channelManager } from './ChannelManager';
|
2 | import { Task, TaskParams } from "./Task";
|
3 | import { promiseNodeify } from './promise-nodeify';
|
4 |
|
5 | export class TaskManager {
|
6 | service:string;
|
7 |
|
8 | constructor() {
|
9 | this.service = "unknown";
|
10 | Task.taskManager = this;
|
11 | }
|
12 |
|
13 | createTask(type:string, params:TaskParams): Task {
|
14 | return new Task(type, params);
|
15 | }
|
16 |
|
17 | purgeQueue(taskType:string, cb?) {
|
18 | var abstractTask = new Task(taskType);
|
19 | let promise = abstractTask.purgeQueue();
|
20 | return promiseNodeify(promise, cb);
|
21 | }
|
22 |
|
23 | processTask(taskType, taskCallback, opts?, cb?) {
|
24 | if(typeof opts === "function") {
|
25 | cb = opts;
|
26 | opts = {};
|
27 | }
|
28 | var abstractTask = new Task(taskType);
|
29 | let promise = abstractTask.processTask(opts, taskCallback);
|
30 | return promiseNodeify(promise, cb);
|
31 | }
|
32 | } |
\ | No newline at end of file |