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/09/02 16:02:22 UTC
svn commit: r810507 -
/incubator/uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java
Author: cwiklik
Date: Wed Sep 2 14:02:22 2009
New Revision: 810507
URL: http://svn.apache.org/viewvc?rev=810507&view=rev
Log:
UIMA-1540 Added a testcase to send multiple CASes to a service using direct UIMA AS client API
Modified:
incubator/uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java
Modified: incubator/uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java
URL: http://svn.apache.org/viewvc/incubator/uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java?rev=810507&r1=810506&r2=810507&view=diff
==============================================================================
--- incubator/uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java (original)
+++ incubator/uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/TestUimaASExtended.java Wed Sep 2 14:02:22 2009
@@ -76,7 +76,6 @@
public BaseTestSupport superRef = null;
-
/**
@@ -88,6 +87,28 @@
System.out.println("UIMA_HOME="+System.getenv("UIMA_HOME")+System.getProperty("file.separator")+"bin"+System.getProperty("file.separator")+"dd2spring.xsl");
}
+ public void testClientProcess() throws Exception
+ {
+ System.out.println("-------------- testClientProcess -------------");
+ // Instantiate Uima AS Client
+ BaseUIMAAsynchronousEngine_impl uimaAsEngine = new BaseUIMAAsynchronousEngine_impl();
+ // Deploy Uima AS Primitive Service
+ deployService(uimaAsEngine, relativePath+"/Deploy_PersonTitleAnnotator.xml");
+ Map<String, Object> appCtx = buildContext( String.valueOf(broker.getMasterConnectorURI()),"PersonTitleAnnotatorQueue" );
+ initialize(uimaAsEngine, appCtx);
+ waitUntilInitialized();
+
+ for( int i=0; i < 100; i++ ) {
+ CAS cas = uimaAsEngine.getCAS();
+ cas.setDocumentText("Some Text");
+ System.out.println("UIMA AS Client Sending CAS#"+(i+1)+" Request to a Service");
+ uimaAsEngine.sendCAS(cas);
+ }
+ uimaAsEngine.collectionProcessingComplete();
+ uimaAsEngine.stop();
+ }
+
+
public void testClientCpcTimeout() throws Exception
{
System.out.println("-------------- testClientCpcTimeout -------------");