summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAndrew Branson <andrew.branson@cern.ch>2014-01-29 20:58:14 +0100
committerAndrew Branson <andrew.branson@cern.ch>2014-01-29 20:58:14 +0100
commit8dbae9edabf67e6a69ec4e5dbed8dd5ec55a3d67 (patch)
treec2d8f6e4dde7651511820f29c8dc0ba9e1ae98aa
parentc8b9d2d31f0758951d912472be2cb3867b0c3dd6 (diff)
Removed Job.getAgentProxy() as it shouldn't be necessary
Removed hanging if in AgentProxy.execute
-rw-r--r--src/main/java/com/c2kernel/entity/agent/Job.java6
-rw-r--r--src/main/java/com/c2kernel/entity/proxy/AgentProxy.java1
2 files changed, 0 insertions, 7 deletions
diff --git a/src/main/java/com/c2kernel/entity/agent/Job.java b/src/main/java/com/c2kernel/entity/agent/Job.java
index eecbe19..7717fdb 100644
--- a/src/main/java/com/c2kernel/entity/agent/Job.java
+++ b/src/main/java/com/c2kernel/entity/agent/Job.java
@@ -254,12 +254,6 @@ public class Job implements C2KLocalObject
return item;
}
- public AgentProxy getAgentProxy() throws ObjectNotFoundException, InvalidEntityPathException {
- if (agent == null)
- agent = (AgentProxy) Gateway.getProxyManager().getProxy(new EntityPath(getAgentId()));
- return agent;
- }
-
public String getDescription()
{
String desc = (String) actProps.get("Description");
diff --git a/src/main/java/com/c2kernel/entity/proxy/AgentProxy.java b/src/main/java/com/c2kernel/entity/proxy/AgentProxy.java
index 3569421..f76af10 100644
--- a/src/main/java/com/c2kernel/entity/proxy/AgentProxy.java
+++ b/src/main/java/com/c2kernel/entity/proxy/AgentProxy.java
@@ -167,7 +167,6 @@ public class AgentProxy extends EntityProxy
if (error.length() > 0)
throw new InvalidDataException(error, "");
}
- else if (job.isOutcomeRequired())
job.setAgentId(getSystemKey());
Logger.msg(3, "AgentProxy - submitting job to item proxy");