You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2009/02/24 22:15:00 UTC
svn commit: r747548 -
/incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java
Author: cwiklik
Date: Tue Feb 24 21:15:00 2009
New Revision: 747548
URL: http://svn.apache.org/viewvc?rev=747548&view=rev
Log:
UIMA-1293 - committing Burn's new test cases
Modified:
incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java
Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java?rev=747548&r1=747547&r2=747548&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java Tue Feb 24 21:15:00 2009
@@ -759,6 +759,30 @@
runTest(null, eeUimaEngine,String.valueOf(broker.getMasterConnectorURI()),"TopLevelTaeQueue", 1, PROCESS_LATCH);
}
+ /**
+ * First CM feeds 100 CASes to a "merger" CM that generates one output CAS for every 5 input.
+ * Second CM creates unique document text that is checked by the last component.
+ * The default FC should let 4 childless CASes through, replacing every 5th by its child.
+ *
+ * @throws Exception
+ */
+ public void testProcessWithAggregateUsingCollocatedMerger() throws Exception
+ {
+ System.out.println("-------------- testProcessWithAggregateUsingRemoteMerger -------------");
+ BaseUIMAAsynchronousEngine_impl eeUimaEngine = new BaseUIMAAsynchronousEngine_impl();
+ deployService(eeUimaEngine, relativePath+"/Deploy_AggregateWithCollocatedMerger.xml");
+ runTest(null, eeUimaEngine,String.valueOf(broker.getMasterConnectorURI()),"TopLevelTaeQueue", 1, PROCESS_LATCH);
+ }
+
+ public void testProcessWithAggregateUsingRemoteMerger() throws Exception
+ {
+ System.out.println("-------------- testProcessWithAggregateUsingRemoteMerger -------------");
+ BaseUIMAAsynchronousEngine_impl eeUimaEngine = new BaseUIMAAsynchronousEngine_impl();
+ deployService(eeUimaEngine, relativePath+"/Deploy_RemoteCasMerger.xml");
+ deployService(eeUimaEngine, relativePath+"/Deploy_AggregateWithRemoteMerger.xml");
+ runTest(null, eeUimaEngine,String.valueOf(broker.getMasterConnectorURI()),"TopLevelTaeQueue", 1, PROCESS_LATCH);
+ }
+
public void testClientWithAggregateMultiplier() throws Exception
{
System.out.println("-------------- testClientWithAggregateMultiplier -------------");