svn commit: r951028 - /uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java

[eae]

Author: eae
Date: Thu Jun  3 15:14:32 2010
New Revision: 951028

URL: http://svn.apache.org/viewvc?rev=951028&view=rev
Log:
UIMA-1794

Modified:
    
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java

Modified: 
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java
URL: 
http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java?rev=951028&r1=951027&r2=951028&view=diff
==============================================================================
--- 
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java
 (original)
+++ 
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/aae/jms_adapter/JmsAnalysisEngineServiceStub.java
 Thu Jun  3 15:14:32 2010
@@ -78,10 +78,14 @@ public class JmsAnalysisEngineServiceStu
 
   public static final String PARAM_BIN_SERIALIZTION = "binary_serialization";
 
+  public static final String PARAM_IGNORE_PROCESS_ERRORS = 
"ignore_process_errors";
+
   private Object mux = new Object();
 
   private boolean cpcReceived;
 
+  private boolean ignoreErrors = false;
+
   private UimaAsynchronousEngine uimaEEEngine;
 
   public JmsAnalysisEngineServiceStub(Resource owner, Parameter[] parameters)
@@ -107,6 +111,8 @@ public class JmsAnalysisEngineServiceStu
         getMetaTimeout = Integer.parseInt(parameters[i].getValue());
       } else if (PARAM_CPC_TIMEOUT.equalsIgnoreCase(parameters[i].getName())) {
         cpcTimeout = Integer.parseInt(parameters[i].getValue());
+      } else if 
(PARAM_IGNORE_PROCESS_ERRORS.equalsIgnoreCase(parameters[i].getName())) {
+        ignoreErrors = parameters[i].getValue().equalsIgnoreCase("true");
       }
     }
 
@@ -172,7 +178,8 @@ public class JmsAnalysisEngineServiceStu
     try {
       uimaEEEngine.sendAndReceiveCAS(aCAS);
     } catch (ResourceProcessException e) {
-      throw new ResourceServiceException(e);
+      if (!ignoreErrors)
+        throw new ResourceServiceException(e);
     }
   }