ExternalProcessJob.java
1.83 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
/*
* Decompiled with CFR 0_118.
*
* Could not load the following classes:
* org.osgi.service.event.Event
*/
package com.day.cq.workflow.job;
import java.io.Serializable;
import java.util.Dictionary;
import java.util.Hashtable;
import java.util.Map;
import org.osgi.service.event.Event;
public class ExternalProcessJob
implements Serializable {
private static final long serialVersionUID = 5718625605490930738L;
public static final String JOB_TOPIC = "com/day/cq/workflow/external/job";
public static final String JOB_TOPIC_WC = "com/day/cq/workflow/external/job/*";
public static final String WORKFLOW_JOB = "com.day.cq.workflow.job";
public static final String WORKFLOW_JOB_ID = "com.day.cq.workflow.jobid";
protected Map serializedItem;
public ExternalProcessJob(Map serializedItem) {
if (serializedItem == null) {
throw new IllegalArgumentException("Resource must not be null.");
}
this.serializedItem = serializedItem;
}
public Map getWorkItemMap() {
return this.serializedItem;
}
public Event createJobEvent(Integer retryCount, String jobId) {
Hashtable<String, Object> props = new Hashtable<String, Object>();
props.put("com.day.cq.workflow.job", this);
props.put("event.job.retries", retryCount);
if (this.serializedItem.get("workflowModelId") != null) {
String workflowModelId = (String)this.serializedItem.get("workflowModelId");
workflowModelId = workflowModelId.replace(":", "_");
props.put("event.job.topic", "com/day/cq/workflow/external/job" + workflowModelId);
} else {
props.put("event.job.topic", "com/day/cq/workflow/external/job");
}
props.put("com.day.cq.workflow.jobid", jobId);
return new Event("org/apache/sling/event/job", props);
}
}