forked from D-Net/dnet-hadoop
recover of Message and MessageType class
This commit is contained in:
parent
33f4696d6e
commit
820d729e99
|
@ -0,0 +1,58 @@
|
||||||
|
|
||||||
|
package eu.dnetlib.message;
|
||||||
|
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
|
public class Message {
|
||||||
|
|
||||||
|
private String workflowId;
|
||||||
|
|
||||||
|
private String jobName;
|
||||||
|
|
||||||
|
private MessageType type;
|
||||||
|
|
||||||
|
private Map<String, String> body;
|
||||||
|
|
||||||
|
public Message() {
|
||||||
|
}
|
||||||
|
|
||||||
|
public Message(final String workflowId, final String jobName, final MessageType type,
|
||||||
|
final Map<String, String> body) {
|
||||||
|
this.workflowId = workflowId;
|
||||||
|
this.jobName = jobName;
|
||||||
|
this.type = type;
|
||||||
|
this.body = body;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getWorkflowId() {
|
||||||
|
return workflowId;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setWorkflowId(final String workflowId) {
|
||||||
|
this.workflowId = workflowId;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getJobName() {
|
||||||
|
return jobName;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setJobName(final String jobName) {
|
||||||
|
this.jobName = jobName;
|
||||||
|
}
|
||||||
|
|
||||||
|
public MessageType getType() {
|
||||||
|
return type;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setType(final MessageType type) {
|
||||||
|
this.type = type;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Map<String, String> getBody() {
|
||||||
|
return body;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setBody(final Map<String, String> body) {
|
||||||
|
this.body = body;
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,6 @@
|
||||||
|
|
||||||
|
package eu.dnetlib.message;
|
||||||
|
|
||||||
|
public enum MessageType {
|
||||||
|
ONGOING, REPORT
|
||||||
|
}
|
Loading…
Reference in New Issue