blob: e58170d4eaa9379c55cbcf328542d967dcb49087 (
plain)
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
|
package com.c2kernel.lifecycle.instance;
import java.util.Enumeration;
import java.util.Iterator;
import com.c2kernel.entity.Agent;
import com.c2kernel.entity.AgentHelper;
import com.c2kernel.entity.agent.Job;
import com.c2kernel.entity.agent.JobArrayList;
import com.c2kernel.lifecycle.instance.stateMachine.Transitions;
import com.c2kernel.lookup.AgentPath;
import com.c2kernel.lookup.RolePath;
import com.c2kernel.utils.CastorXMLUtility;
import com.c2kernel.utils.Logger;
final class JobPusher extends Thread {
private final Activity activity;
private final RolePath myRole;
JobPusher(Activity activity, RolePath role) {
this.activity = activity;
this.myRole = role;
}
public void run()
{
Thread.currentThread().setName("Agent job pusher for "+activity.getName()+" to role "+myRole);
for (Enumeration e = myRole.getChildren(); e.hasMoreElements();)
{
AgentPath nextAgent = (AgentPath)e.nextElement();
Logger.msg(7, "Activity.pushJobsToAgents() - Calculating jobs for " + nextAgent.getAgentName());
try
{
// get joblist for user
JobArrayList jobList = new JobArrayList(this.activity.calculateJobs(nextAgent, false));
// only transmit start, complete and resume jobs
for (Iterator element = jobList.list.iterator(); element.hasNext();)
{
Job thisJob = (Job) element.next();
if (thisJob.getPossibleTransition() != Transitions.START
&& thisJob.getPossibleTransition() != Transitions.COMPLETE
&& thisJob.getPossibleTransition() != Transitions.RESUME
&& thisJob.getPossibleTransition() != Transitions.SUSPEND
&& thisJob.getPossibleTransition() != Transitions.REASSIGN)
element.remove();
}
Logger.msg(7, "Activity.pushJobsToAgents() - User will receive " + jobList.list.size() + " jobs");
String stringJobs = CastorXMLUtility.marshall(jobList);
// push it to the agent
org.omg.CORBA.Object agentIOR = nextAgent.getIOR();
Agent thisAgent = AgentHelper.narrow(agentIOR);
Logger.debug("Calling agent "+thisAgent.getSystemKey()+" from "+activity.getPath());
thisAgent.refreshJobList(this.activity.getItemEntityPath().getSysKey(), activity.getPath(), stringJobs);
}
catch (Exception ex)
{
Logger.error(
"Agent "
+ nextAgent.getAgentName()
+ " of role "
+ myRole
+ " could not be found to be informed of a change in "
+ this.activity.getItemEntityPath().getSysKey());
Logger.error(ex);
}
}
}
}
|
