You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by de...@apache.org on 2014/04/16 17:34:49 UTC
svn commit: r1587947 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-web/src/main/java/org/apache/uima/ducc/ws/DuccData.java
Author: degenaro
Date: Wed Apr 16 15:34:48 2014
New Revision: 1587947
URL: http://svn.apache.org/r1587947
Log:
UIMA-3751 Expanded utilities for response construction
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-web/src/main/java/org/apache/uima/ducc/ws/DuccData.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-web/src/main/java/org/apache/uima/ducc/ws/DuccData.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-web/src/main/java/org/apache/uima/ducc/ws/DuccData.java?rev=1587947&r1=1587946&r2=1587947&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-web/src/main/java/org/apache/uima/ducc/ws/DuccData.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-web/src/main/java/org/apache/uima/ducc/ws/DuccData.java Wed Apr 16 15:34:48 2014
@@ -19,6 +19,7 @@
package org.apache.uima.ducc.ws;
import java.util.Iterator;
+import java.util.Map.Entry;
import java.util.concurrent.ConcurrentSkipListMap;
import org.apache.uima.ducc.common.utils.DuccLogger;
@@ -30,6 +31,7 @@ import org.apache.uima.ducc.transport.ev
import org.apache.uima.ducc.transport.event.common.DuccWorkReservation;
import org.apache.uima.ducc.transport.event.common.IDuccTypes.DuccType;
import org.apache.uima.ducc.transport.event.common.IDuccWork;
+import org.apache.uima.ducc.transport.event.common.IDuccWorkJob;
import org.apache.uima.ducc.transport.event.common.IDuccWorkService.ServiceDeploymentType;
import org.apache.uima.ducc.transport.event.common.history.HistoryPersistenceManager;
import org.apache.uima.ducc.transport.event.common.history.IHistoryPersistenceManager;
@@ -372,6 +374,23 @@ public class DuccData {
}
}
+ public IDuccWorkJob getJob(DuccId duccId) {
+ IDuccWorkJob retVal = null;
+ ConcurrentSkipListMap<JobInfo,JobInfo> sortedJobs = getSortedJobs();
+ if(sortedJobs.size()> 0) {
+ Iterator<Entry<JobInfo, JobInfo>> iterator = sortedJobs.entrySet().iterator();
+ while(iterator.hasNext()) {
+ JobInfo jobInfo = iterator.next().getValue();
+ DuccWorkJob job = jobInfo.getJob();
+ if(job.getDuccId().getFriendly() == duccId.getFriendly()) {
+ retVal = job;
+ break;
+ }
+ }
+ }
+ return retVal;
+ }
+
public ConcurrentSkipListMap<JobInfo,JobInfo> getSortedJobs() {
return sortedJobs;
}