ScheduleTaskItem.java
2.62 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
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
package com.taobao.pamirs.schedule.taskmanager;
/**
* 任务队列类型
* @author xuannan
*
*/
public class ScheduleTaskItem {
public enum TaskItemSts {
ACTIVTE, FINISH, HALT
}
/**
* 处理任务类型
*/
private String taskType;
/**
* 原始任务类型
*/
private String baseTaskType;
/**
* 完成状态
*/
private TaskItemSts sts = TaskItemSts.ACTIVTE;
/**
* 任务处理需要的参数
*/
private String dealParameter="";
/**
* 任务处理情况,用于任务处理器会写一些信息
*/
private String dealDesc="";
public String getBaseTaskType() {
return baseTaskType;
}
public void setBaseTaskType(String baseTaskType) {
this.baseTaskType = baseTaskType;
}
/**
* 队列的环境标识
*/
private String ownSign;
/**
* 任务队列ID
*/
private String taskItem;
/**
* 持有当前任务队列的任务处理器
*/
private String currentScheduleServer;
/**
* 正在申请此任务队列的任务处理器
*/
private String requestScheduleServer;
/**
* 数据版本号
*/
private long version;
public String getTaskType() {
return taskType;
}
public void setTaskType(String taskType) {
this.taskType = taskType;
}
public String getTaskItem() {
return taskItem;
}
public void setTaskItem(String aTaskItem) {
this.taskItem = aTaskItem;
}
public String getCurrentScheduleServer() {
return currentScheduleServer;
}
public void setCurrentScheduleServer(String currentScheduleServer) {
this.currentScheduleServer = currentScheduleServer;
}
public String getRequestScheduleServer() {
return requestScheduleServer;
}
public void setRequestScheduleServer(String requestScheduleServer) {
this.requestScheduleServer = requestScheduleServer;
}
public long getVersion() {
return version;
}
public void setVersion(long version) {
this.version = version;
}
public String getOwnSign() {
return ownSign;
}
public void setOwnSign(String ownSign) {
this.ownSign = ownSign;
}
public String toString(){
return "TASK_TYPE=" + this.taskType +":TASK_ITEM=" + this.taskItem
+ ":CUR_SERVER=" + this.currentScheduleServer + ":REQ_SERVER=" + this.requestScheduleServer+":DEAL_PARAMETER="+this.dealParameter;
}
public void setDealDesc(String dealDesc) {
this.dealDesc = dealDesc;
}
public String getDealDesc() {
return dealDesc;
}
public void setSts(TaskItemSts sts) {
this.sts = sts;
}
public TaskItemSts getSts() {
return sts;
}
public void setDealParameter(String dealParameter) {
this.dealParameter = dealParameter;
}
public String getDealParameter() {
return dealParameter;
}
}