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;
}
}