Author: cwiklik
Date: Mon Aug 12 13:19:26 2013
New Revision: 1513132

URL: http://svn.apache.org/r1513132
Log:
UIMA-924 supports onUimaServiceExit callback

Modified:
    
uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/BaseTestSupport.java

Modified: 
uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/BaseTestSupport.java
URL: 
http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/BaseTestSupport.java?rev=1513132&r1=1513131&r2=1513132&view=diff
==============================================================================
--- 
uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/BaseTestSupport.java
 (original)
+++ 
uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/BaseTestSupport.java
 Mon Aug 12 13:19:26 2013
@@ -32,6 +32,7 @@ import java.util.concurrent.Semaphore;
 
 import javax.jms.Message;
 
+import org.apache.uima.aae.UimaASApplicationEvent.EventTrigger;
 import org.apache.uima.aae.client.UimaASProcessStatus;
 import org.apache.uima.aae.client.UimaASProcessStatusImpl;
 import org.apache.uima.aae.client.UimaAsBaseCallbackListener;
@@ -653,6 +654,10 @@ public abstract class BaseTestSupport ex
       System.out.println("runTest: Received onBeforeMessageSend() Notification 
With CAS:"
               + status.getCasReferenceId());
     }
+    public void onUimaAsServiceExit(EventTrigger cause) {
+        System.out.println("runTest: Received onUimaAsServiceExit() 
Notification With Cause:"
+                + cause.name());
+    }
     public synchronized void entityProcessComplete(CAS aCAS, 
EntityProcessStatus aProcessStatus, List<AnalysisEnginePerformanceMetrics> 
componentMetricsList) {
       entityProcessComplete(aCAS, aProcessStatus);
       StringBuilder sb = new StringBuilder("--- CAS");
@@ -752,12 +757,13 @@ public abstract class BaseTestSupport ex
             processCountLatch.countDown();
           }
         } else if (processCountLatch != null) {
+               processCountLatch.countDown();
           if (!expectedException) {
             unexpectedException = true;
             System.out.println("runTest:  ... when expecting normal 
completion!");
-          }
-          while (processCountLatch.getCount() > 0) {
-            processCountLatch.countDown();
+            while (processCountLatch.getCount() > 0) {
+                processCountLatch.countDown();
+              }
           }
         }
       }
@@ -781,6 +787,7 @@ public abstract class BaseTestSupport ex
                     .println("To fix, use 
uima-as/src/main/lib/optional/activemq-optional-5.0.0.jar");
             unexpectedException = true;
             processCountLatch.countDown();
+
             return;
           }
         }


Reply via email to