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/07/01 21:17:07 UTC
svn commit: r790322 -
/incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java
Author: cwiklik
Date: Wed Jul 1 19:17:07 2009
New Revision: 790322
URL: http://svn.apache.org/viewvc?rev=790322&view=rev
Log:
UIMA-1391 Changed a testcase to test sending msgs to scaled out top level service
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=790322&r1=790321&r2=790322&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 Wed Jul 1 19:17:07 2009
@@ -215,7 +215,7 @@
appCtx.put(UimaAsynchronousEngine.CasPoolSize, 1 );
deployService(eeUimaEngine, relativePath+"/Deploy_NoOpAnnotator.xml");
String containerId = deployService(eeUimaEngine, relativePath+"/Deploy_AggregateAnnotatorWithInternalCM1000Docs.xml");
- spinShutdownThread(eeUimaEngine, 5000, containerId, SpringContainerDeployer.QUIESCE_AND_STOP );
+ spinShutdownThread(eeUimaEngine, 3000, containerId, SpringContainerDeployer.QUIESCE_AND_STOP );
runTest(appCtx,eeUimaEngine,String.valueOf(broker.getMasterConnectorURI()),"TopLevelTaeQueue", 2, EXCEPTION_LATCH);
@@ -263,6 +263,8 @@
final BaseUIMAAsynchronousEngine_impl eeUimaEngine = new BaseUIMAAsynchronousEngine_impl();
deployService(eeUimaEngine, relativePath+"/Deploy_NoOpAnnotator.xml");
deployService(eeUimaEngine, relativePath+"/Deploy_RemoteCasMultiplierWith1MillionDocs.xml");
+ deployService(eeUimaEngine, relativePath+"/Deploy_RemoteCasMultiplierWith1MillionDocs.xml");
+ deployService(eeUimaEngine, relativePath+"/Deploy_CMAggregateWithRemote1MillionDocsCM.xml");
deployService(eeUimaEngine, relativePath+"/Deploy_CMAggregateWithRemote1MillionDocsCM.xml");
Thread t = new Thread() {
public void run()
@@ -280,7 +282,7 @@
}
};
t.start();
- runTest(null,eeUimaEngine,String.valueOf(broker.getMasterConnectorURI()),"TopLevelTaeQueue", 1, PROCESS_LATCH);
+ runTest(null,eeUimaEngine,String.valueOf(broker.getMasterConnectorURI()),"TopLevelTaeQueue", 2, PROCESS_LATCH);
}
public void testAggregateCMWithFailedRemoteDelegate() throws Exception