TaskTrackerAppContext.java
2.4 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
package com.github.ltsopensource.tasktracker.domain;
import com.github.ltsopensource.core.AppContext;
import com.github.ltsopensource.core.constant.Level;
import com.github.ltsopensource.core.remoting.RemotingClientDelegate;
import com.github.ltsopensource.tasktracker.monitor.StopWorkingMonitor;
import com.github.ltsopensource.tasktracker.runner.RunnerFactory;
import com.github.ltsopensource.tasktracker.runner.RunnerPool;
import com.github.ltsopensource.tasktracker.support.JobPullMachine;
/**
* @author Robert HG (254963746@qq.com) on 3/30/15.
*/
public class TaskTrackerAppContext extends AppContext {
private RemotingClientDelegate remotingClient;
// runner 线程池
private RunnerPool runnerPool;
//
private RunnerFactory runnerFactory;
// Pull Job Machine
private JobPullMachine jobPullMachine;
private StopWorkingMonitor stopWorkingMonitor;
/**
* 业务日志记录级别
*/
private Level bizLogLevel;
/**
* 执行任务的class
*/
private Class<?> jobRunnerClass;
public StopWorkingMonitor getStopWorkingMonitor() {
return stopWorkingMonitor;
}
public void setStopWorkingMonitor(StopWorkingMonitor stopWorkingMonitor) {
this.stopWorkingMonitor = stopWorkingMonitor;
}
public RunnerPool getRunnerPool() {
return runnerPool;
}
public void setRunnerPool(RunnerPool runnerPool) {
this.runnerPool = runnerPool;
}
public Level getBizLogLevel() {
return bizLogLevel;
}
public void setBizLogLevel(Level bizLogLevel) {
this.bizLogLevel = bizLogLevel;
}
public Class<?> getJobRunnerClass() {
return jobRunnerClass;
}
public void setJobRunnerClass(Class<?> jobRunnerClass) {
this.jobRunnerClass = jobRunnerClass;
}
public RunnerFactory getRunnerFactory() {
return runnerFactory;
}
public void setRunnerFactory(RunnerFactory runnerFactory) {
this.runnerFactory = runnerFactory;
}
public RemotingClientDelegate getRemotingClient() {
return remotingClient;
}
public void setRemotingClient(RemotingClientDelegate remotingClient) {
this.remotingClient = remotingClient;
}
public JobPullMachine getJobPullMachine() {
return jobPullMachine;
}
public void setJobPullMachine(JobPullMachine jobPullMachine) {
this.jobPullMachine = jobPullMachine;
}
}