svn commit: r1516149 - /uima/sandbox/uima-ducc/trunk/uima-ducc-cli/src/main/java/org/apache/uima/ducc/cli/aio/AllInOne.java

[de...@apache.org]

Author: degenaro
Date: Wed Aug 21 12:52:41 2013
New Revision: 1516149

URL: http://svn.apache.org/r1516149
Log:
UIMA-3166 DUCC command line interface (CLI) All-In-One with zero work items

Modified:
    uima/sandbox/uima-ducc/trunk/uima-ducc-cli/src/main/java/org/apache/uima/ducc/cli/aio/AllInOne.java

Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-cli/src/main/java/org/apache/uima/ducc/cli/aio/AllInOne.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-cli/src/main/java/org/apache/uima/ducc/cli/aio/AllInOne.java?rev=1516149&r1=1516148&r2=1516149&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-cli/src/main/java/org/apache/uima/ducc/cli/aio/AllInOne.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-cli/src/main/java/org/apache/uima/ducc/cli/aio/AllInOne.java Wed Aug 21 12:52:41 2013
@@ -88,15 +88,25 @@ public class AllInOne extends CliBase {
 		mh.frameworkTrace(cid, mid, "exit");
 	}
 
+	private class NoWorkItems extends Exception {
+		private static final long serialVersionUID = 1L;
+	}
+	
 	private void initialize() throws Exception {
 		String mid = "initialize";
 		mh.frameworkTrace(cid, mid, "enter");
 		// Generator
 		casGenerator = new CasGenerator(jobRequestProperties, mh);
 		casGenerator.initialize();
-		// Pipeline
-		casPipeline = new CasPipeline(jobRequestProperties, mh);
-		casPipeline.initialize();
+		int total = casGenerator.getTotal();
+		if(total > 0) {
+			// Pipeline
+			casPipeline = new CasPipeline(jobRequestProperties, mh);
+			casPipeline.initialize();
+		}
+		else {
+			throw new NoWorkItems();
+		}
 		mh.frameworkTrace(cid, mid, "exit");
 	}
 	
@@ -126,10 +136,16 @@ public class AllInOne extends CliBase {
 	public void go() throws Exception {
 		String mid = "go";
 		mh.frameworkTrace(cid, mid, "enter");
-		examine();
-		initialize();
-		process();
-		statistics();
+		try {
+			examine();
+			initialize();
+			process();
+			statistics();
+		}
+		catch(NoWorkItems e) {
+			String message = "no work items";
+			mh.warn(cid, mid, message);
+		}
 		mh.frameworkTrace(cid, mid, "exit");
 	}