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 2013/11/22 19:52:50 UTC
svn commit: r1544638 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/client/WorkItem.java
Author: degenaro
Date: Fri Nov 22 18:52:50 2013
New Revision: 1544638
URL: http://svn.apache.org/r1544638
Log:
UIMA-3442 DUCC pre-R1.0 has classes that look like tests in the main?
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/client/WorkItem.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/client/WorkItem.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/client/WorkItem.java?rev=1544638&r1=1544637&r2=1544638&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/client/WorkItem.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/client/WorkItem.java Fri Nov 22 18:52:50 2013
@@ -62,6 +62,10 @@ public class WorkItem implements Runnabl
public AtomicBoolean isLost = new AtomicBoolean(false);
+ // <for testing only!!!>
+ boolean injectRandom = false;
+ // </for testing only!!!>
+
public WorkItem(UimaAsynchronousEngine client, CasTuple casTuple, DuccId duccId, IWorkItemMonitor workItemMonitor) {
init(client, casTuple, duccId, workItemMonitor);
}
@@ -125,18 +129,6 @@ public class WorkItem implements Runnabl
return callbackState;
}
- protected void injectRandomThrowable() throws Throwable {
- // < *** TEST ONLY!!! *** >
- final boolean test = false;
- if(test) {
- Random random = new Random();
- if(random.nextBoolean()) {
- throw new Throwable("just testing Throwable handler");
- }
- }
- // </ *** TEST ONLY!!! *** >
- }
-
public void run() {
String methodName = "run";
duccOut.debug(methodName, jobId, duccMsg.fetch("enter"));
@@ -149,7 +141,14 @@ public class WorkItem implements Runnabl
duccOut.debug(methodName, null, "seqNo:"+getSeqNo()+" "+callbackState.getState());
client.sendAndReceiveCAS(cas, analysisEnginePerformanceMetricsList);
duccOut.debug(methodName, null, "seqNo:"+getSeqNo()+" "+"send and receive returned");
- //injectRandomThrowable();
+ // <for testing only!!!>
+ if(injectRandom) {
+ Random random = new Random();
+ if(random.nextBoolean()) {
+ throw new Throwable("just testing Throwable handler");
+ }
+ }
+ // </for testing only!!!>
if(!isLost.get()) {
ended();
}