You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by ea...@apache.org on 2009/01/09 19:53:31 UTC
svn commit: r733114 [2/3] - in
/incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src: main/scripts/
test/resources/deploy/ test/resources/deploy/expected/
test/resources/deploy/expected/envVar/
Modified: incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/Deploy_MeetingFinder.xml
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/Deploy_MeetingFinder.xml?rev=733114&r1=733113&r2=733114&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/Deploy_MeetingFinder.xml (original)
+++ incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/Deploy_MeetingFinder.xml Fri Jan 9 10:53:30 2009
@@ -1,479 +1,490 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--==================================================================================-->
- <!-- Generated from -->
- <!-- file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/deploy/Deploy_MeetingFinder.xml -->
- <!-- 6 October, 2008, 4:02:05 P.M. -->
- <!--==================================================================================-->
- <!DOCTYPE beans
- PUBLIC "-//Spring//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
-<beans>
-
- <!-- Factory for specific external queue broker: -->
- <!-- tcp://localhost:61616 -->
- <bean id="qBroker_tcp_c__ss_localhost_c_61616"
- class="org.apache.activemq.ActiveMQConnectionFactory">
- <property name="brokerURL" value="tcp://localhost:61616"/>
- <property name="prefetchPolicy" ref="prefetchPolicy"/>
- </bean>
-
- <!-- Creates an instance of the ResourceManager -->
- <bean id="resourceManager" class="org.apache.uima.aae.UimaClassFactory"
- factory-method="produceResourceManager"
- singleton="true"/>
-
- <!-- Creates an instance of the CasManager -->
- <bean id="casManager" class="org.apache.uima.aae.AsynchAECasManager_impl"
- singleton="true">
- <constructor-arg index="0" ref="resourceManager"/>
-
- <!-- Defines how many CASes will be in the CAS pool -->
- <property name="casPoolSize" value="1"/>
-
- <!-- Initial heap size for CASes -->
- <property name="initialFsHeapSize" value="2000000"/>
- </bean>
-
- <!-- Creates a Shared Cache -->
- <bean id="inProcessCache" class="org.apache.uima.aae.InProcessCache"/>
-
- <!-- Create prefetch policy -->
- <bean id="prefetchPolicy" class="org.apache.activemq.ActiveMQPrefetchPolicy">
- <property name="queuePrefetch" value="0"/>
- </bean>
-
- <!--=================================-->
- <!-- E r r o r D e t a i l s -->
- <!--=================================-->
- <bean id="errorConfig__TCnt_0_TWndw_0_Action_"
- class="org.apache.uima.aae.error.Threshold"
- singleton="true">
- <property name="threshold" value="0"/>
- <property name="window" value="0"/>
- <property name="action" value=""/>
- </bean>
-
- <bean id="errorConfig__Action_" class="org.apache.uima.aae.error.Threshold"
- singleton="true">
- <property name="action" value=""/>
- </bean>
-
- <bean id="errorConfig__Rtry_0_Action_terminate"
- class="org.apache.uima.aae.error.Threshold"
- singleton="true">
- <property name="maxRetries" value="0"/>
- <property name="action" value="terminate"/>
- </bean>
-
- <bean id="errorConfig__Rtry_0_Continue_false_TCnt_0_TWndw_0_Action_"
- class="org.apache.uima.aae.error.Threshold"
- singleton="true">
- <property name="maxRetries" value="0"/>
- <property name="continueOnRetryFailure" value="false"/>
- <property name="threshold" value="0"/>
- <property name="window" value="0"/>
- <property name="action" value=""/>
- </bean>
-
- <bean id="errorConfig__Rtry_0_Continue_false_TCnt_100_TWndw_1000_Action_terminate"
- class="org.apache.uima.aae.error.Threshold"
- singleton="true">
- <property name="maxRetries" value="0"/>
- <property name="continueOnRetryFailure" value="false"/>
- <property name="threshold" value="100"/>
- <property name="window" value="1000"/>
- <property name="action" value="terminate"/>
- </bean>
-
-
- <!--input queue for service-->
- <bean id="top_level_input_queue_service_1"
- class="org.apache.activemq.command.ActiveMQQueue">
- <constructor-arg index="0" value="MeetingFinderQueue"/>
- </bean>
- <!--=======================================-->
- <!-- Async Aggregate: MeetingFinderQueue_1 -->
- <!--=======================================-->
- <bean id="asAggr_ctlr_MeetingFinderQueue_1"
- class="org.apache.uima.aae.controller.AggregateAnalysisEngineController_impl"
- init-method="initialize">
- <constructor-arg index="0">
- <null/>
- </constructor-arg>
- <constructor-arg index="1" value="MeetingFinderQueue"/>
- <constructor-arg index="2"
- value="file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/descriptors/meetingFinder/MeetingFinderAggregate.xml"/>
- <constructor-arg index="3" ref="casManager"/>
- <constructor-arg index="4" ref="inProcessCache"/>
- <constructor-arg index="5" ref="delegate_map_MeetingFinderQueue_1"/>
- <property name="outputChannel" ref="outChnl_MeetingFinderQueue_1"/>
- <property name="serviceEndpointName" value="top_level_input_queue_service_1"/>
- <property name="controllerBeanName" value="asAggr_ctlr_MeetingFinderQueue_1"/>
- <property name="errorHandlerChain" ref="err_hdlr_chn_MeetingFinderQueue_1"/>
- <property name="flowControllerDescriptor"
- value="*importByName:org.apache.uima.flow.FixedFlowController"/>
- </bean>
-
- <!--===================================================-->
- <!-- M E S S A G E H A N D L E R: aggregate_input -->
- <!-- for controller: asAggr_ctlr_MeetingFinderQueue_1 -->
- <!--===================================================-->
-
- <bean id="aggregate_input_metaMsgHandler_MeetingFinderQueue_1"
- class="org.apache.uima.aae.handler.input.MetadataRequestHandler_impl">
- <constructor-arg index="0" value="MetadataRequestHandler"/>
- <property name="controller" ref="asAggr_ctlr_MeetingFinderQueue_1"/>
- <property name="delegate"
- ref="aggregate_input_processRequestHandler_MeetingFinderQueue_1"/>
- </bean>
-
- <bean id="aggregate_input_processRequestHandler_MeetingFinderQueue_1"
- class="org.apache.uima.aae.handler.input.ProcessRequestHandler_impl">
- <constructor-arg index="0" value="ProcessRequestHandler"/>
- <property name="controller" ref="asAggr_ctlr_MeetingFinderQueue_1"/>
- </bean>
-
- <!-- Create the endpoints + output channels, one per delegate -->
-
-
- <!-- ==================================== -->
- <!-- CollectionReader -->
- <!-- ** Delegate Endpoint ** -->
- <!-- ==================================== -->
- <bean id="endpt_CollectionReader_1.1"
- class="org.apache.uima.aae.controller.Endpoint_impl">
-
- <!-- Broker URI -->
- <property name="serverURI" value="vm://localhost"/>
-
- <!-- Delegate key name or remote queue name -->
- <property name="endpoint" value="inQ_CollectionReader_1.1"/>
-
- <!-- Timeouts -->
- <property name="metadataRequestTimeout" value="60000"/>
- <property name="processRequestTimeout" value="0"/>
- <property name="collectionProcessCompleteTimeout" value="0"/>
- <property name="concurrentRequestConsumers" value="1"/>
- <property name="concurrentReplyConsumers" value="1"/>
- </bean>
-
- <!-- ==================================== -->
- <!-- TokenAndSentence -->
- <!-- ** Delegate Endpoint ** -->
- <!-- ==================================== -->
- <bean id="endpt_TokenAndSentence_1.2"
- class="org.apache.uima.aae.controller.Endpoint_impl">
-
- <!-- Broker URI -->
- <property name="serverURI" value="vm://localhost"/>
-
- <!-- Delegate key name or remote queue name -->
- <property name="endpoint" value="inQ_TokenAndSentence_1.2"/>
-
- <!-- Timeouts -->
- <property name="metadataRequestTimeout" value="60000"/>
- <property name="processRequestTimeout" value="100000"/>
- <property name="collectionProcessCompleteTimeout" value="0"/>
- <property name="concurrentRequestConsumers" value="1"/>
- <property name="concurrentReplyConsumers" value="1"/>
- </bean>
-
- <!-- ==================================== -->
- <!-- MeetingDetector -->
- <!-- ** Delegate Endpoint ** -->
- <!-- ==================================== -->
- <bean id="endpt_MeetingDetector_1.3"
- class="org.apache.uima.aae.controller.Endpoint_impl">
-
- <!-- Broker URI -->
- <property name="serverURI" value="vm://localhost"/>
-
- <!-- Delegate key name or remote queue name -->
- <property name="endpoint" value="inQ_MeetingDetector_1.3"/>
-
- <!-- Timeouts -->
- <property name="metadataRequestTimeout" value="60000"/>
- <property name="processRequestTimeout" value="0"/>
- <property name="collectionProcessCompleteTimeout" value="0"/>
- <property name="concurrentRequestConsumers" value="1"/>
- <property name="concurrentReplyConsumers" value="1"/>
- </bean>
-
- <!-- ==================================== -->
- <!-- CasConsumer -->
- <!-- ** Delegate Endpoint ** -->
- <!-- ==================================== -->
- <bean id="endpt_CasConsumer_1.4" class="org.apache.uima.aae.controller.Endpoint_impl">
-
- <!-- Broker URI -->
- <property name="serverURI" value="vm://localhost"/>
-
- <!-- Delegate key name or remote queue name -->
- <property name="endpoint" value="inQ_CasConsumer_1.4"/>
-
- <!-- Timeouts -->
- <property name="metadataRequestTimeout" value="60000"/>
- <property name="processRequestTimeout" value="0"/>
- <property name="collectionProcessCompleteTimeout" value="0"/>
- <property name="concurrentRequestConsumers" value="1"/>
- <property name="concurrentReplyConsumers" value="1"/>
- </bean>
-
- <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
- <!-- JMS msg listener for input queue for: -->
- <!-- top_level_input_queue_service_1 -->
- <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
- <bean id="asAggr_input_q_listenerID_MeetingFinderQueue_1"
- class="org.apache.uima.adapter.jms.activemq.JmsInputChannel">
- <property name="messageHandler" ref="aggregate_input_metaMsgHandler_MeetingFinderQueue_1"/>
- <property name="endpointName" value="top_level_input_queue_service_1"/>
- <property name="controller" ref="asAggr_ctlr_MeetingFinderQueue_1"/>
- <property name="listenerContainer" ref="asAggr_input_msgLsnrCntnr_MeetingFinderQueue_1"/>
- </bean>
-
- <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
- <!-- JMS msg listener container for input queue for: -->
- <!-- top_level_input_queue_service_1 -->
- <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
- <bean id="asAggr_input_msgLsnrCntnr_MeetingFinderQueue_1"
- class="org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer">
-
- <!-- Define number of JMS Consumers -->
- <property name="concurrentConsumers" value="1"/>
-
- <!-- input Queue -->
- <property name="destination" ref="top_level_input_queue_service_1"/>
-
- <!-- POJO to delegate JMS Messages to -->
- <property name="messageListener" ref="asAggr_input_q_listenerID_MeetingFinderQueue_1"/>
- <property name="connectionFactory" ref="qBroker_tcp_c__ss_localhost_c_61616"/>
- <property name="messageSelector" value="Command=2000 OR Command=2002"/>
- </bean>
-
- <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
- <!-- GetMeta JMS msg listener container for input queue for: -->
- <!-- top_level_input_queue_service_1 -->
- <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
- <bean id="asAggr_input_msgLsnrCntnr_MeetingFinderQueue_1_getMeta"
- class="org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer">
-
- <!-- Define number of JMS Consumers -->
- <property name="concurrentConsumers" value="1"/>
-
- <!-- input Queue -->
- <property name="destination" ref="top_level_input_queue_service_1"/>
-
- <!-- POJO to delegate JMS Messages to -->
- <property name="messageListener" ref="asAggr_input_q_listenerID_MeetingFinderQueue_1"/>
- <property name="connectionFactory" ref="qBroker_tcp_c__ss_localhost_c_61616"/>
- <property name="messageSelector" value="Command=2001"/>
- </bean>
-
- <!-- ================================== -->
- <!-- OutputChannel - for flows out of -->
- <!-- this component, both to delegates -->
- <!-- (if aggr) and back up to sender -->
- <!-- ================================== -->
- <bean id="outChnl_MeetingFinderQueue_1"
- class="org.apache.uima.adapter.jms.activemq.JmsOutputChannel"
- init-method="initialize">
- <property name="serviceInputEndpoint" value="MeetingFinderQueue"/>
- <property name="controller" ref="asAggr_ctlr_MeetingFinderQueue_1"/>
- <property name="controllerInputEndpoint" value="asynAggr_retQ_MeetingFinderQueue_1"/>
- </bean>
-
- <!-- map for delegate keys -->
- <bean id="delegate_map_MeetingFinderQueue_1" class="java.util.HashMap"
- singleton="true">
- <constructor-arg>
- <map>
- <entry key="CollectionReader">
- <ref bean="endpt_CollectionReader_1.1"/>
- </entry>
- <entry key="TokenAndSentence">
- <ref bean="endpt_TokenAndSentence_1.2"/>
- </entry>
- <entry key="MeetingDetector">
- <ref bean="endpt_MeetingDetector_1.3"/>
- </entry>
- <entry key="CasConsumer">
- <ref bean="endpt_CasConsumer_1.4"/>
- </entry>
- </map>
- </constructor-arg>
- </bean>
-
-
- <!--========================-->
- <!-- Delegate ErrorHandlers -->
- <!--========================-->
- <bean id="err_hndlr_getMetadataEr_1"
- class="org.apache.uima.aae.error.handler.GetMetaErrorHandler">
- <constructor-arg>
- <map>
- <entry key="CollectionReader">
- <ref bean="errorConfig__Rtry_0_Action_terminate"/>
- </entry>
- <entry key="TokenAndSentence">
- <ref bean="errorConfig__Rtry_0_Action_terminate"/>
- </entry>
- <entry key="MeetingDetector">
- <ref bean="errorConfig__Rtry_0_Action_terminate"/>
- </entry>
- <entry key="CasConsumer">
- <ref bean="errorConfig__Rtry_0_Action_terminate"/>
- </entry>
- </map>
- </constructor-arg>
- </bean>
-
- <bean id="err_hndlr_processCasEr_1"
- class="org.apache.uima.aae.error.handler.ProcessCasErrorHandler">
- <constructor-arg>
- <map>
- <entry key="CollectionReader">
- <ref bean="errorConfig__Rtry_0_Continue_false_TCnt_0_TWndw_0_Action_"/>
- </entry>
- <entry key="TokenAndSentence">
- <ref bean="errorConfig__Rtry_0_Continue_false_TCnt_100_TWndw_1000_Action_terminate"/>
- </entry>
- <entry key="MeetingDetector">
- <ref bean="errorConfig__Rtry_0_Continue_false_TCnt_0_TWndw_0_Action_"/>
- </entry>
- <entry key="CasConsumer">
- <ref bean="errorConfig__Rtry_0_Continue_false_TCnt_0_TWndw_0_Action_"/>
- </entry>
- <entry key="">
- <ref bean="errorConfig__TCnt_0_TWndw_0_Action_"/>
- </entry>
- </map>
- </constructor-arg>
- </bean>
-
- <bean id="err_hndlr_collectionProcessCompleteEr_1"
- class="org.apache.uima.aae.error.handler.CpcErrorHandler">
- <constructor-arg>
- <map>
- <entry key="CollectionReader">
- <ref bean="errorConfig__Action_"/>
- </entry>
- <entry key="TokenAndSentence">
- <ref bean="errorConfig__Action_"/>
- </entry>
- <entry key="MeetingDetector">
- <ref bean="errorConfig__Action_"/>
- </entry>
- <entry key="CasConsumer">
- <ref bean="errorConfig__Action_"/>
- </entry>
- <entry key="">
- <ref bean="errorConfig__Action_"/>
- </entry>
- </map>
- </constructor-arg>
- </bean>
-
-
- <!--=======================-->
- <!-- Error Handler Chain -->
- <!--=======================-->
- <bean id="err_hdlr_chn_MeetingFinderQueue_1"
- class="org.apache.uima.aae.error.ErrorHandlerChain">
- <constructor-arg>
- <list>
- <ref local="err_hndlr_getMetadataEr_1"/>
- <ref local="err_hndlr_processCasEr_1"/>
- <ref local="err_hndlr_collectionProcessCompleteEr_1"/>
- </list>
- </constructor-arg>
- </bean>
- <!--===============================================-->
- <!-- Primitive or non-Async Aggr: CollectionReader -->
- <!--===============================================-->
- <bean id="primitive_ctlr_CollectionReader_1.1"
- class="org.apache.uima.aae.controller.PrimitiveAnalysisEngineController_impl"
- init-method="initialize">
- <constructor-arg index="0" ref="asAggr_ctlr_MeetingFinderQueue_1"/>
-
- <!-- Key name -->
- <constructor-arg index="1" value="CollectionReader"/>
- <constructor-arg index="2"
- value="file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/descriptors/meetingFinder/FileSystemCollectionReader.xml"/>
- <constructor-arg index="3" ref="casManager"/>
- <constructor-arg index="4" ref="inProcessCache"/>
-
- <!-- this parameter is ignored -->
- <constructor-arg index="5" value="10"/>
-
- <!-- scaleout number of instances -->
- <constructor-arg index="6" value="1"/>
-
- <!-- CAS Multiplier poolSize -->
- <constructor-arg index="7" value="2"/>
-
- <!-- CAS Multiplier initial heap size -->
- <constructor-arg index="8" value="2000000"/>
- </bean>
- <!--===============================================-->
- <!-- Primitive or non-Async Aggr: TokenAndSentence -->
- <!--===============================================-->
- <bean id="primitive_ctlr_TokenAndSentence_1.2"
- class="org.apache.uima.aae.controller.PrimitiveAnalysisEngineController_impl"
- init-method="initialize">
- <constructor-arg index="0" ref="asAggr_ctlr_MeetingFinderQueue_1"/>
-
- <!-- Key name -->
- <constructor-arg index="1" value="TokenAndSentence"/>
- <constructor-arg index="2"
- value="file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/descriptors/meetingFinder/SimpleTokenAndSentenceAnnotator.xml"/>
- <constructor-arg index="3" ref="casManager"/>
- <constructor-arg index="4" ref="inProcessCache"/>
-
- <!-- this parameter is ignored -->
- <constructor-arg index="5" value="10"/>
-
- <!-- scaleout number of instances -->
- <constructor-arg index="6" value="1"/>
- </bean>
- <!--==============================================-->
- <!-- Primitive or non-Async Aggr: MeetingDetector -->
- <!--==============================================-->
- <bean id="primitive_ctlr_MeetingDetector_1.3"
- class="org.apache.uima.aae.controller.PrimitiveAnalysisEngineController_impl"
- init-method="initialize">
- <constructor-arg index="0" ref="asAggr_ctlr_MeetingFinderQueue_1"/>
-
- <!-- Key name -->
- <constructor-arg index="1" value="MeetingDetector"/>
- <constructor-arg index="2"
- value="file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/descriptors/meetingFinder/MeetingDetectorTAE.xml"/>
- <constructor-arg index="3" ref="casManager"/>
- <constructor-arg index="4" ref="inProcessCache"/>
-
- <!-- this parameter is ignored -->
- <constructor-arg index="5" value="10"/>
-
- <!-- scaleout number of instances -->
- <constructor-arg index="6" value="1"/>
- </bean>
- <!--==========================================-->
- <!-- Primitive or non-Async Aggr: CasConsumer -->
- <!--==========================================-->
- <bean id="primitive_ctlr_CasConsumer_1.4"
- class="org.apache.uima.aae.controller.PrimitiveAnalysisEngineController_impl"
- init-method="initialize">
- <constructor-arg index="0" ref="asAggr_ctlr_MeetingFinderQueue_1"/>
-
- <!-- Key name -->
- <constructor-arg index="1" value="CasConsumer"/>
- <constructor-arg index="2"
- value="file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/descriptors/meetingFinder/XmiWriterCasConsumer.xml"/>
- <constructor-arg index="3" ref="casManager"/>
- <constructor-arg index="4" ref="inProcessCache"/>
-
- <!-- this parameter is ignored -->
- <constructor-arg index="5" value="10"/>
-
- <!-- scaleout number of instances -->
- <constructor-arg index="6" value="1"/>
- </bean>
+<?xml version="1.0" encoding="UTF-8"?>
+<!--==================================================================================-->
+ <!-- Generated from -->
+ <!-- file:/C:/apache/uima-as-distr/src/test/resources/deploy/Deploy_MeetingFinder.xml -->
+ <!-- 9 January, 2009, 1:45:54 P.M. -->
+ <!--==================================================================================-->
+ <!DOCTYPE beans
+ PUBLIC "-//Spring//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
+<beans>
+
+ <!-- Factory for specific external queue broker: -->
+ <!-- tcp://localhost:61616 -->
+ <bean id="qBroker_tcp_c__ss_localhost_c_61616"
+ class="org.apache.activemq.ActiveMQConnectionFactory">
+ <property name="brokerURL" value="tcp://localhost:61616"/>
+ <property name="prefetchPolicy" ref="prefetchPolicy"/>
+ </bean>
+
+ <!-- Factory for specific external queue broker: -->
+ <!-- tcp://localhost:61616 -->
+ <bean id="qBroker_tcp_c__ss_localhost_c_61616-reply"
+ class="org.apache.activemq.ActiveMQConnectionFactory">
+ <property name="brokerURL" value="tcp://localhost:61616"/>
+ <property name="prefetchPolicy" ref="prefetchPolicy-reply"/>
+ </bean>
+
+ <!-- Creates an instance of the ResourceManager -->
+ <bean id="resourceManager" class="org.apache.uima.aae.UimaClassFactory"
+ factory-method="produceResourceManager"
+ singleton="true"/>
+
+ <!-- Creates an instance of the CasManager -->
+ <bean id="casManager" class="org.apache.uima.aae.AsynchAECasManager_impl"
+ singleton="true">
+ <constructor-arg index="0" ref="resourceManager"/>
+
+ <!-- Defines how many CASes will be in the CAS pool -->
+ <property name="casPoolSize" value="1"/>
+
+ <!-- Initial heap size for CASes -->
+ <property name="initialFsHeapSize" value="2000000"/>
+ </bean>
+
+ <!-- Creates a Shared Cache -->
+ <bean id="inProcessCache" class="org.apache.uima.aae.InProcessCache"/>
+
+ <!-- Create prefetch policy -->
+ <bean id="prefetchPolicy" class="org.apache.activemq.ActiveMQPrefetchPolicy">
+ <property name="queuePrefetch" value="0"/>
+ </bean>
+ <bean id="prefetchPolicy-reply" class="org.apache.activemq.ActiveMQPrefetchPolicy">
+ <property name="queuePrefetch" value="1"/>
+ </bean>
+
+ <!--=================================-->
+ <!-- E r r o r D e t a i l s -->
+ <!--=================================-->
+ <bean id="errorConfig__TCnt_0_TWndw_0_Action_"
+ class="org.apache.uima.aae.error.Threshold"
+ singleton="true">
+ <property name="threshold" value="0"/>
+ <property name="window" value="0"/>
+ <property name="action" value=""/>
+ </bean>
+
+ <bean id="errorConfig__Action_" class="org.apache.uima.aae.error.Threshold"
+ singleton="true">
+ <property name="action" value=""/>
+ </bean>
+
+ <bean id="errorConfig__Rtry_0_Action_terminate"
+ class="org.apache.uima.aae.error.Threshold"
+ singleton="true">
+ <property name="maxRetries" value="0"/>
+ <property name="action" value="terminate"/>
+ </bean>
+
+ <bean id="errorConfig__Rtry_0_Continue_false_TCnt_0_TWndw_0_Action_"
+ class="org.apache.uima.aae.error.Threshold"
+ singleton="true">
+ <property name="maxRetries" value="0"/>
+ <property name="continueOnRetryFailure" value="false"/>
+ <property name="threshold" value="0"/>
+ <property name="window" value="0"/>
+ <property name="action" value=""/>
+ </bean>
+
+ <bean id="errorConfig__Rtry_0_Continue_false_TCnt_100_TWndw_1000_Action_terminate"
+ class="org.apache.uima.aae.error.Threshold"
+ singleton="true">
+ <property name="maxRetries" value="0"/>
+ <property name="continueOnRetryFailure" value="false"/>
+ <property name="threshold" value="100"/>
+ <property name="window" value="1000"/>
+ <property name="action" value="terminate"/>
+ </bean>
+
+
+ <!--input queue for service-->
+ <bean id="top_level_input_queue_service_1"
+ class="org.apache.activemq.command.ActiveMQQueue">
+ <constructor-arg index="0" value="MeetingFinderQueue"/>
+ </bean>
+ <!--=======================================-->
+ <!-- Async Aggregate: MeetingFinderQueue_1 -->
+ <!--=======================================-->
+ <bean id="asAggr_ctlr_MeetingFinderQueue_1"
+ class="org.apache.uima.aae.controller.AggregateAnalysisEngineController_impl"
+ init-method="initialize">
+ <constructor-arg index="0">
+ <null/>
+ </constructor-arg>
+ <constructor-arg index="1" value="MeetingFinderQueue"/>
+ <constructor-arg index="2"
+ value="file:/C:/apache/uima-as-distr/src/test/resources/descriptors/meetingFinder/MeetingFinderAggregate.xml"/>
+ <constructor-arg index="3" ref="casManager"/>
+ <constructor-arg index="4" ref="inProcessCache"/>
+ <constructor-arg index="5" ref="delegate_map_MeetingFinderQueue_1"/>
+ <property name="outputChannel" ref="outChnl_MeetingFinderQueue_1"/>
+ <property name="serviceEndpointName" value="top_level_input_queue_service_1"/>
+ <property name="controllerBeanName" value="asAggr_ctlr_MeetingFinderQueue_1"/>
+ <property name="errorHandlerChain" ref="err_hdlr_chn_MeetingFinderQueue_1"/>
+ <property name="flowControllerDescriptor"
+ value="*importByName:org.apache.uima.flow.FixedFlowController"/>
+ </bean>
+
+ <!--===================================================-->
+ <!-- M E S S A G E H A N D L E R: aggregate_input -->
+ <!-- for controller: asAggr_ctlr_MeetingFinderQueue_1 -->
+ <!--===================================================-->
+
+ <bean id="aggregate_input_metaMsgHandler_MeetingFinderQueue_1"
+ class="org.apache.uima.aae.handler.input.MetadataRequestHandler_impl">
+ <constructor-arg index="0" value="MetadataRequestHandler"/>
+ <property name="controller" ref="asAggr_ctlr_MeetingFinderQueue_1"/>
+ <property name="delegate"
+ ref="aggregate_input_processRequestHandler_MeetingFinderQueue_1"/>
+ </bean>
+
+ <bean id="aggregate_input_processRequestHandler_MeetingFinderQueue_1"
+ class="org.apache.uima.aae.handler.input.ProcessRequestHandler_impl">
+ <constructor-arg index="0" value="ProcessRequestHandler"/>
+ <property name="controller" ref="asAggr_ctlr_MeetingFinderQueue_1"/>
+ </bean>
+
+ <!-- Create the endpoints + output channels, one per delegate -->
+
+
+ <!-- ==================================== -->
+ <!-- CollectionReader -->
+ <!-- ** Delegate Endpoint ** -->
+ <!-- ==================================== -->
+ <bean id="endpt_CollectionReader_1.1"
+ class="org.apache.uima.aae.controller.Endpoint_impl">
+
+ <!-- Broker URI -->
+ <property name="serverURI" value="vm://localhost"/>
+
+ <!-- Delegate key name or remote queue name -->
+ <property name="endpoint" value="inQ_CollectionReader_1.1"/>
+
+ <!-- Timeouts -->
+ <property name="metadataRequestTimeout" value="60000"/>
+ <property name="processRequestTimeout" value="0"/>
+ <property name="collectionProcessCompleteTimeout" value="0"/>
+ <property name="concurrentRequestConsumers" value="1"/>
+ <property name="concurrentReplyConsumers" value="1"/>
+ </bean>
+
+ <!-- ==================================== -->
+ <!-- TokenAndSentence -->
+ <!-- ** Delegate Endpoint ** -->
+ <!-- ==================================== -->
+ <bean id="endpt_TokenAndSentence_1.2"
+ class="org.apache.uima.aae.controller.Endpoint_impl">
+
+ <!-- Broker URI -->
+ <property name="serverURI" value="vm://localhost"/>
+
+ <!-- Delegate key name or remote queue name -->
+ <property name="endpoint" value="inQ_TokenAndSentence_1.2"/>
+
+ <!-- Timeouts -->
+ <property name="metadataRequestTimeout" value="60000"/>
+ <property name="processRequestTimeout" value="100000"/>
+ <property name="collectionProcessCompleteTimeout" value="0"/>
+ <property name="concurrentRequestConsumers" value="1"/>
+ <property name="concurrentReplyConsumers" value="1"/>
+ </bean>
+
+ <!-- ==================================== -->
+ <!-- MeetingDetector -->
+ <!-- ** Delegate Endpoint ** -->
+ <!-- ==================================== -->
+ <bean id="endpt_MeetingDetector_1.3"
+ class="org.apache.uima.aae.controller.Endpoint_impl">
+
+ <!-- Broker URI -->
+ <property name="serverURI" value="vm://localhost"/>
+
+ <!-- Delegate key name or remote queue name -->
+ <property name="endpoint" value="inQ_MeetingDetector_1.3"/>
+
+ <!-- Timeouts -->
+ <property name="metadataRequestTimeout" value="60000"/>
+ <property name="processRequestTimeout" value="0"/>
+ <property name="collectionProcessCompleteTimeout" value="0"/>
+ <property name="concurrentRequestConsumers" value="1"/>
+ <property name="concurrentReplyConsumers" value="1"/>
+ </bean>
+
+ <!-- ==================================== -->
+ <!-- CasConsumer -->
+ <!-- ** Delegate Endpoint ** -->
+ <!-- ==================================== -->
+ <bean id="endpt_CasConsumer_1.4" class="org.apache.uima.aae.controller.Endpoint_impl">
+
+ <!-- Broker URI -->
+ <property name="serverURI" value="vm://localhost"/>
+
+ <!-- Delegate key name or remote queue name -->
+ <property name="endpoint" value="inQ_CasConsumer_1.4"/>
+
+ <!-- Timeouts -->
+ <property name="metadataRequestTimeout" value="60000"/>
+ <property name="processRequestTimeout" value="0"/>
+ <property name="collectionProcessCompleteTimeout" value="0"/>
+ <property name="concurrentRequestConsumers" value="1"/>
+ <property name="concurrentReplyConsumers" value="1"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener for input queue for: -->
+ <!-- top_level_input_queue_service_1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="asAggr_input_q_listenerID_MeetingFinderQueue_1"
+ class="org.apache.uima.adapter.jms.activemq.JmsInputChannel">
+ <property name="messageHandler" ref="aggregate_input_metaMsgHandler_MeetingFinderQueue_1"/>
+ <property name="endpointName" value="top_level_input_queue_service_1"/>
+ <property name="controller" ref="asAggr_ctlr_MeetingFinderQueue_1"/>
+ <property name="listenerContainer" ref="asAggr_input_msgLsnrCntnr_MeetingFinderQueue_1"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener container for input queue for: -->
+ <!-- top_level_input_queue_service_1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="asAggr_input_msgLsnrCntnr_MeetingFinderQueue_1"
+ class="org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer">
+
+ <!-- Define number of JMS Consumers -->
+ <property name="concurrentConsumers" value="1"/>
+
+ <!-- input Queue -->
+ <property name="destination" ref="top_level_input_queue_service_1"/>
+
+ <!-- POJO to delegate JMS Messages to -->
+ <property name="messageListener" ref="asAggr_input_q_listenerID_MeetingFinderQueue_1"/>
+ <property name="connectionFactory" ref="qBroker_tcp_c__ss_localhost_c_61616"/>
+ <property name="messageSelector" value="Command=2000 OR Command=2002"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- GetMeta JMS msg listener container for input queue for: -->
+ <!-- top_level_input_queue_service_1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="asAggr_input_msgLsnrCntnr_MeetingFinderQueue_1_getMeta"
+ class="org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer">
+
+ <!-- Define number of JMS Consumers -->
+ <property name="concurrentConsumers" value="1"/>
+
+ <!-- input Queue -->
+ <property name="destination" ref="top_level_input_queue_service_1"/>
+
+ <!-- POJO to delegate JMS Messages to -->
+ <property name="messageListener" ref="asAggr_input_q_listenerID_MeetingFinderQueue_1"/>
+ <property name="connectionFactory" ref="qBroker_tcp_c__ss_localhost_c_61616"/>
+ <property name="messageSelector" value="Command=2001"/>
+ </bean>
+
+ <!-- ================================== -->
+ <!-- OutputChannel - for flows out of -->
+ <!-- this component, both to delegates -->
+ <!-- (if aggr) and back up to sender -->
+ <!-- ================================== -->
+ <bean id="outChnl_MeetingFinderQueue_1"
+ class="org.apache.uima.adapter.jms.activemq.JmsOutputChannel"
+ init-method="initialize">
+ <property name="serviceInputEndpoint" value="MeetingFinderQueue"/>
+ <property name="controller" ref="asAggr_ctlr_MeetingFinderQueue_1"/>
+ <property name="controllerInputEndpoint" value="asynAggr_retQ_MeetingFinderQueue_1"/>
+ </bean>
+
+ <!-- map for delegate keys -->
+ <bean id="delegate_map_MeetingFinderQueue_1" class="java.util.HashMap"
+ singleton="true">
+ <constructor-arg>
+ <map>
+ <entry key="CollectionReader">
+ <ref bean="endpt_CollectionReader_1.1"/>
+ </entry>
+ <entry key="TokenAndSentence">
+ <ref bean="endpt_TokenAndSentence_1.2"/>
+ </entry>
+ <entry key="MeetingDetector">
+ <ref bean="endpt_MeetingDetector_1.3"/>
+ </entry>
+ <entry key="CasConsumer">
+ <ref bean="endpt_CasConsumer_1.4"/>
+ </entry>
+ </map>
+ </constructor-arg>
+ </bean>
+
+
+ <!--========================-->
+ <!-- Delegate ErrorHandlers -->
+ <!--========================-->
+ <bean id="err_hndlr_getMetadataEr_1"
+ class="org.apache.uima.aae.error.handler.GetMetaErrorHandler">
+ <constructor-arg>
+ <map>
+ <entry key="CollectionReader">
+ <ref bean="errorConfig__Rtry_0_Action_terminate"/>
+ </entry>
+ <entry key="TokenAndSentence">
+ <ref bean="errorConfig__Rtry_0_Action_terminate"/>
+ </entry>
+ <entry key="MeetingDetector">
+ <ref bean="errorConfig__Rtry_0_Action_terminate"/>
+ </entry>
+ <entry key="CasConsumer">
+ <ref bean="errorConfig__Rtry_0_Action_terminate"/>
+ </entry>
+ </map>
+ </constructor-arg>
+ </bean>
+
+ <bean id="err_hndlr_processCasEr_1"
+ class="org.apache.uima.aae.error.handler.ProcessCasErrorHandler">
+ <constructor-arg>
+ <map>
+ <entry key="CollectionReader">
+ <ref bean="errorConfig__Rtry_0_Continue_false_TCnt_0_TWndw_0_Action_"/>
+ </entry>
+ <entry key="TokenAndSentence">
+ <ref bean="errorConfig__Rtry_0_Continue_false_TCnt_100_TWndw_1000_Action_terminate"/>
+ </entry>
+ <entry key="MeetingDetector">
+ <ref bean="errorConfig__Rtry_0_Continue_false_TCnt_0_TWndw_0_Action_"/>
+ </entry>
+ <entry key="CasConsumer">
+ <ref bean="errorConfig__Rtry_0_Continue_false_TCnt_0_TWndw_0_Action_"/>
+ </entry>
+ <entry key="">
+ <ref bean="errorConfig__TCnt_0_TWndw_0_Action_"/>
+ </entry>
+ </map>
+ </constructor-arg>
+ </bean>
+
+ <bean id="err_hndlr_collectionProcessCompleteEr_1"
+ class="org.apache.uima.aae.error.handler.CpcErrorHandler">
+ <constructor-arg>
+ <map>
+ <entry key="CollectionReader">
+ <ref bean="errorConfig__Action_"/>
+ </entry>
+ <entry key="TokenAndSentence">
+ <ref bean="errorConfig__Action_"/>
+ </entry>
+ <entry key="MeetingDetector">
+ <ref bean="errorConfig__Action_"/>
+ </entry>
+ <entry key="CasConsumer">
+ <ref bean="errorConfig__Action_"/>
+ </entry>
+ <entry key="">
+ <ref bean="errorConfig__Action_"/>
+ </entry>
+ </map>
+ </constructor-arg>
+ </bean>
+
+
+ <!--=======================-->
+ <!-- Error Handler Chain -->
+ <!--=======================-->
+ <bean id="err_hdlr_chn_MeetingFinderQueue_1"
+ class="org.apache.uima.aae.error.ErrorHandlerChain">
+ <constructor-arg>
+ <list>
+ <ref local="err_hndlr_getMetadataEr_1"/>
+ <ref local="err_hndlr_processCasEr_1"/>
+ <ref local="err_hndlr_collectionProcessCompleteEr_1"/>
+ </list>
+ </constructor-arg>
+ </bean>
+ <!--===============================================-->
+ <!-- Primitive or non-Async Aggr: CollectionReader -->
+ <!--===============================================-->
+ <bean id="primitive_ctlr_CollectionReader_1.1"
+ class="org.apache.uima.aae.controller.PrimitiveAnalysisEngineController_impl"
+ init-method="initialize">
+ <constructor-arg index="0" ref="asAggr_ctlr_MeetingFinderQueue_1"/>
+
+ <!-- Key name -->
+ <constructor-arg index="1" value="CollectionReader"/>
+ <constructor-arg index="2"
+ value="file:/C:/apache/uima-as-distr/src/test/resources/descriptors/meetingFinder/FileSystemCollectionReader.xml"/>
+ <constructor-arg index="3" ref="casManager"/>
+ <constructor-arg index="4" ref="inProcessCache"/>
+
+ <!-- this parameter is ignored -->
+ <constructor-arg index="5" value="10"/>
+
+ <!-- scaleout number of instances -->
+ <constructor-arg index="6" value="1"/>
+
+ <!-- CAS Multiplier poolSize -->
+ <constructor-arg index="7" value="2"/>
+
+ <!-- CAS Multiplier initial heap size -->
+ <constructor-arg index="8" value="2000000"/>
+ </bean>
+ <!--===============================================-->
+ <!-- Primitive or non-Async Aggr: TokenAndSentence -->
+ <!--===============================================-->
+ <bean id="primitive_ctlr_TokenAndSentence_1.2"
+ class="org.apache.uima.aae.controller.PrimitiveAnalysisEngineController_impl"
+ init-method="initialize">
+ <constructor-arg index="0" ref="asAggr_ctlr_MeetingFinderQueue_1"/>
+
+ <!-- Key name -->
+ <constructor-arg index="1" value="TokenAndSentence"/>
+ <constructor-arg index="2"
+ value="file:/C:/apache/uima-as-distr/src/test/resources/descriptors/meetingFinder/SimpleTokenAndSentenceAnnotator.xml"/>
+ <constructor-arg index="3" ref="casManager"/>
+ <constructor-arg index="4" ref="inProcessCache"/>
+
+ <!-- this parameter is ignored -->
+ <constructor-arg index="5" value="10"/>
+
+ <!-- scaleout number of instances -->
+ <constructor-arg index="6" value="1"/>
+ </bean>
+ <!--==============================================-->
+ <!-- Primitive or non-Async Aggr: MeetingDetector -->
+ <!--==============================================-->
+ <bean id="primitive_ctlr_MeetingDetector_1.3"
+ class="org.apache.uima.aae.controller.PrimitiveAnalysisEngineController_impl"
+ init-method="initialize">
+ <constructor-arg index="0" ref="asAggr_ctlr_MeetingFinderQueue_1"/>
+
+ <!-- Key name -->
+ <constructor-arg index="1" value="MeetingDetector"/>
+ <constructor-arg index="2"
+ value="file:/C:/apache/uima-as-distr/src/test/resources/descriptors/meetingFinder/MeetingDetectorTAE.xml"/>
+ <constructor-arg index="3" ref="casManager"/>
+ <constructor-arg index="4" ref="inProcessCache"/>
+
+ <!-- this parameter is ignored -->
+ <constructor-arg index="5" value="10"/>
+
+ <!-- scaleout number of instances -->
+ <constructor-arg index="6" value="1"/>
+ </bean>
+ <!--==========================================-->
+ <!-- Primitive or non-Async Aggr: CasConsumer -->
+ <!--==========================================-->
+ <bean id="primitive_ctlr_CasConsumer_1.4"
+ class="org.apache.uima.aae.controller.PrimitiveAnalysisEngineController_impl"
+ init-method="initialize">
+ <constructor-arg index="0" ref="asAggr_ctlr_MeetingFinderQueue_1"/>
+
+ <!-- Key name -->
+ <constructor-arg index="1" value="CasConsumer"/>
+ <constructor-arg index="2"
+ value="file:/C:/apache/uima-as-distr/src/test/resources/descriptors/meetingFinder/XmiWriterCasConsumer.xml"/>
+ <constructor-arg index="3" ref="casManager"/>
+ <constructor-arg index="4" ref="inProcessCache"/>
+
+ <!-- this parameter is ignored -->
+ <constructor-arg index="5" value="10"/>
+
+ <!-- scaleout number of instances -->
+ <constructor-arg index="6" value="1"/>
+ </bean>
</beans>
\ No newline at end of file
Modified: incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/aggrRmtConcurrentReply.xml
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/aggrRmtConcurrentReply.xml?rev=733114&r1=733113&r2=733114&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/aggrRmtConcurrentReply.xml (original)
+++ incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/aggrRmtConcurrentReply.xml Fri Jan 9 10:53:30 2009
@@ -1,8 +1,8 @@
<?xml version="1.0" encoding="UTF-8"?>
<!--==================================================================================-->
- <!-- Generated from -->
- <!-- file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/deploy/aggrRmtConcurrentReply.xml -->
- <!-- 6 October, 2008, 3:16:12 P.M. -->
+ <!-- Generated from -->
+ <!-- file:/C:/apache/uima-as-distr/src/test/resources/deploy/aggrRmtConcurrentReply.xml -->
+ <!-- 9 January, 2009, 1:45:24 P.M. -->
<!--==================================================================================-->
<!DOCTYPE beans
PUBLIC "-//Spring//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
@@ -24,6 +24,22 @@
<property name="prefetchPolicy" ref="prefetchPolicy"/>
</bean>
+ <!-- Factory for specific external queue broker: -->
+ <!-- tcp://localhost:61616 -->
+ <bean id="qBroker_tcp_c__ss_localhost_c_61616-reply"
+ class="org.apache.activemq.ActiveMQConnectionFactory">
+ <property name="brokerURL" value="tcp://localhost:61616"/>
+ <property name="prefetchPolicy" ref="prefetchPolicy-reply"/>
+ </bean>
+
+ <!-- Factory for specific external queue broker: -->
+ <!-- tcp://some.remote:12345 -->
+ <bean id="qBroker_tcp_c__ss_some.remote_c_12345-reply"
+ class="org.apache.activemq.ActiveMQConnectionFactory">
+ <property name="brokerURL" value="tcp://some.remote:12345"/>
+ <property name="prefetchPolicy" ref="prefetchPolicy-reply"/>
+ </bean>
+
<!-- Creates an instance of the ResourceManager -->
<bean id="resourceManager" class="org.apache.uima.aae.UimaClassFactory"
factory-method="produceResourceManager"
@@ -48,6 +64,9 @@
<bean id="prefetchPolicy" class="org.apache.activemq.ActiveMQPrefetchPolicy">
<property name="queuePrefetch" value="0"/>
</bean>
+ <bean id="prefetchPolicy-reply" class="org.apache.activemq.ActiveMQPrefetchPolicy">
+ <property name="queuePrefetch" value="1"/>
+ </bean>
<!--=================================-->
<!-- E r r o r D e t a i l s -->
@@ -99,7 +118,7 @@
</constructor-arg>
<constructor-arg index="1" value="RoomNumberAnnotatorQueue"/>
<constructor-arg index="2"
- value="file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex4/MeetingDetectorTAE.xml"/>
+ value="file:/C:/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex4/MeetingDetectorTAE.xml"/>
<constructor-arg index="3" ref="casManager"/>
<constructor-arg index="4" ref="inProcessCache"/>
<constructor-arg index="5" ref="delegate_map_RoomNumberAnnotatorQueue_1"/>
@@ -196,7 +215,7 @@
<!-- Queue name used for replies, on the remote broker -->
<property name="replyToEndpoint"
- value="rmtRtrnQ_RoomNumberAnnotatorQueue_1_DateTime_9.2.34.805b199f85:11cd396016e:-7fff"/>
+ value="rmtRtrnQ_RoomNumberAnnotatorQueue_1_DateTime_9.2.35.129-628e130c:11ebcb68398:-8000"/>
<!-- Timeouts -->
<property name="metadataRequestTimeout" value="60000"/>
@@ -285,7 +304,7 @@
<bean id="rmtRtrnQ_RoomNumberAnnotatorQueue_1_DateTime"
class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg index="0"
- value="rmtRtrnQ_RoomNumberAnnotatorQueue_1_DateTime_9.2.34.805b199f85:11cd396016e:-7fff"/>
+ value="rmtRtrnQ_RoomNumberAnnotatorQueue_1_DateTime_9.2.35.129-628e130c:11ebcb68398:-8000"/>
</bean>
<!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~-->
@@ -319,7 +338,7 @@
<!-- POJO to delegate JMS Messages to -->
<property name="messageListener"
ref="asAggr_return_q_listenerID_RoomNumberAnnotatorQueue_1_DateTime"/>
- <property name="connectionFactory" ref="qBroker_tcp_c__ss_some.remote_c_12345"/>
+ <property name="connectionFactory" ref="qBroker_tcp_c__ss_some.remote_c_12345-reply"/>
</bean>
<!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~-->
@@ -329,7 +348,7 @@
<bean id="destinationResolver_RoomNumberAnnotatorQueue_1_DateTime"
class="org.apache.uima.adapter.jms.activemq.TempDestinationResolver"
singleton="false">
- <property name="connectionFactory" ref="qBroker_tcp_c__ss_some.remote_c_12345"/>
+ <property name="connectionFactory" ref="qBroker_tcp_c__ss_some.remote_c_12345-reply"/>
</bean>
<!-- ================================== -->
@@ -449,7 +468,7 @@
<!-- Key name -->
<constructor-arg index="1" value="RoomNumber"/>
<constructor-arg index="2"
- value="file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex4/../ex2/RoomNumberAnnotator.xml"/>
+ value="file:/C:/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex4/../ex2/RoomNumberAnnotator.xml"/>
<constructor-arg index="3" ref="casManager"/>
<constructor-arg index="4" ref="inProcessCache"/>
@@ -470,7 +489,7 @@
<!-- Key name -->
<constructor-arg index="1" value="Meeting"/>
<constructor-arg index="2"
- value="file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex4/MeetingAnnotator.xml"/>
+ value="file:/C:/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex4/MeetingAnnotator.xml"/>
<constructor-arg index="3" ref="casManager"/>
<constructor-arg index="4" ref="inProcessCache"/>
Modified: incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/defaultingAE.xml
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/defaultingAE.xml?rev=733114&r1=733113&r2=733114&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/defaultingAE.xml (original)
+++ incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/defaultingAE.xml Fri Jan 9 10:53:30 2009
@@ -1,9 +1,9 @@
<?xml version="1.0" encoding="UTF-8"?>
-<!--==================================================================================-->
- <!-- Generated from -->
- <!-- file:/C:/a/Eclipse/3.3/apache/uima-as-distr/src/test/resources/deploy/defaultingAE.xml -->
- <!-- 2 November, 2007, 2:33:38 P.M. -->
- <!--==================================================================================-->
+<!--==========================================================================-->
+ <!-- Generated from -->
+ <!-- file:/C:/apache/uima-as-distr/src/test/resources/deploy/defaultingAE.xml -->
+ <!-- 9 January, 2009, 1:45:37 P.M. -->
+ <!--==========================================================================-->
<!DOCTYPE beans
PUBLIC "-//Spring//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
@@ -16,6 +16,14 @@
<property name="prefetchPolicy" ref="prefetchPolicy"/>
</bean>
+ <!-- Factory for specific external queue broker: -->
+ <!-- tcp://localhost:61616 -->
+ <bean id="qBroker_tcp_c__ss_localhost_c_61616-reply"
+ class="org.apache.activemq.ActiveMQConnectionFactory">
+ <property name="brokerURL" value="tcp://localhost:61616"/>
+ <property name="prefetchPolicy" ref="prefetchPolicy-reply"/>
+ </bean>
+
<!-- Creates an instance of the ResourceManager -->
<bean id="resourceManager" class="org.apache.uima.aae.UimaClassFactory"
factory-method="produceResourceManager"
@@ -40,6 +48,9 @@
<bean id="prefetchPolicy" class="org.apache.activemq.ActiveMQPrefetchPolicy">
<property name="queuePrefetch" value="0"/>
</bean>
+ <bean id="prefetchPolicy-reply" class="org.apache.activemq.ActiveMQPrefetchPolicy">
+ <property name="queuePrefetch" value="1"/>
+ </bean>
<!--=================================-->
<!-- E r r o r D e t a i l s -->
@@ -76,7 +87,7 @@
<!-- Key name -->
<constructor-arg index="1" value="RoomNumberAnnotatorQueue"/>
<constructor-arg index="2"
- value="file:/C:/a/Eclipse/3.3/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex2/RoomNumberAnnotator.xml"/>
+ value="file:/C:/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex2/RoomNumberAnnotator.xml"/>
<constructor-arg index="3" ref="casManager"/>
<constructor-arg index="4" ref="inProcessCache"/>
Modified: incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/defaultingAEaggr.xml
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/defaultingAEaggr.xml?rev=733114&r1=733113&r2=733114&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/defaultingAEaggr.xml (original)
+++ incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/defaultingAEaggr.xml Fri Jan 9 10:53:30 2009
@@ -1,9 +1,9 @@
<?xml version="1.0" encoding="UTF-8"?>
-<!--==================================================================================-->
- <!-- Generated from -->
- <!-- file:/C:/a/Eclipse/3.3/apache/uima-as-distr/src/test/resources/deploy/defaultingAEaggr.xml -->
- <!-- 2 November, 2007, 2:33:35 P.M. -->
- <!--==================================================================================-->
+<!--==============================================================================-->
+ <!-- Generated from -->
+ <!-- file:/C:/apache/uima-as-distr/src/test/resources/deploy/defaultingAEaggr.xml -->
+ <!-- 9 January, 2009, 1:45:40 P.M. -->
+ <!--==============================================================================-->
<!DOCTYPE beans
PUBLIC "-//Spring//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
@@ -16,6 +16,14 @@
<property name="prefetchPolicy" ref="prefetchPolicy"/>
</bean>
+ <!-- Factory for specific external queue broker: -->
+ <!-- tcp://localhost:61616 -->
+ <bean id="qBroker_tcp_c__ss_localhost_c_61616-reply"
+ class="org.apache.activemq.ActiveMQConnectionFactory">
+ <property name="brokerURL" value="tcp://localhost:61616"/>
+ <property name="prefetchPolicy" ref="prefetchPolicy-reply"/>
+ </bean>
+
<!-- Creates an instance of the ResourceManager -->
<bean id="resourceManager" class="org.apache.uima.aae.UimaClassFactory"
factory-method="produceResourceManager"
@@ -40,6 +48,9 @@
<bean id="prefetchPolicy" class="org.apache.activemq.ActiveMQPrefetchPolicy">
<property name="queuePrefetch" value="0"/>
</bean>
+ <bean id="prefetchPolicy-reply" class="org.apache.activemq.ActiveMQPrefetchPolicy">
+ <property name="queuePrefetch" value="1"/>
+ </bean>
<!--=================================-->
<!-- E r r o r D e t a i l s -->
@@ -76,7 +87,7 @@
<!-- Key name -->
<constructor-arg index="1" value="RoomNumberAnnotatorQueue"/>
<constructor-arg index="2"
- value="file:/C:/a/Eclipse/3.3/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex4/MeetingDetectorTAE.xml"/>
+ value="file:/C:/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex4/MeetingDetectorTAE.xml"/>
<constructor-arg index="3" ref="casManager"/>
<constructor-arg index="4" ref="inProcessCache"/>
Modified: incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/defaultingAEaggrAsync.xml
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/defaultingAEaggrAsync.xml?rev=733114&r1=733113&r2=733114&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/defaultingAEaggrAsync.xml (original)
+++ incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/defaultingAEaggrAsync.xml Fri Jan 9 10:53:30 2009
@@ -1,8 +1,8 @@
<?xml version="1.0" encoding="UTF-8"?>
<!--==================================================================================-->
- <!-- Generated from -->
- <!-- file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/deploy/defaultingAEaggrAsync.xml -->
- <!-- 6 October, 2008, 4:35:28 P.M. -->
+ <!-- Generated from -->
+ <!-- file:/C:/apache/uima-as-distr/src/test/resources/deploy/defaultingAEaggrAsync.xml -->
+ <!-- 9 January, 2009, 1:45:44 P.M. -->
<!--==================================================================================-->
<!DOCTYPE beans
PUBLIC "-//Spring//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
@@ -16,6 +16,14 @@
<property name="prefetchPolicy" ref="prefetchPolicy"/>
</bean>
+ <!-- Factory for specific external queue broker: -->
+ <!-- tcp://localhost:61616 -->
+ <bean id="qBroker_tcp_c__ss_localhost_c_61616-reply"
+ class="org.apache.activemq.ActiveMQConnectionFactory">
+ <property name="brokerURL" value="tcp://localhost:61616"/>
+ <property name="prefetchPolicy" ref="prefetchPolicy-reply"/>
+ </bean>
+
<!-- Creates an instance of the ResourceManager -->
<bean id="resourceManager" class="org.apache.uima.aae.UimaClassFactory"
factory-method="produceResourceManager"
@@ -40,6 +48,9 @@
<bean id="prefetchPolicy" class="org.apache.activemq.ActiveMQPrefetchPolicy">
<property name="queuePrefetch" value="0"/>
</bean>
+ <bean id="prefetchPolicy-reply" class="org.apache.activemq.ActiveMQPrefetchPolicy">
+ <property name="queuePrefetch" value="1"/>
+ </bean>
<!--=================================-->
<!-- E r r o r D e t a i l s -->
@@ -91,7 +102,7 @@
</constructor-arg>
<constructor-arg index="1" value="RoomNumberAnnotatorQueue"/>
<constructor-arg index="2"
- value="file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex4/MeetingDetectorTAE.xml"/>
+ value="file:/C:/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex4/MeetingDetectorTAE.xml"/>
<constructor-arg index="3" ref="casManager"/>
<constructor-arg index="4" ref="inProcessCache"/>
<constructor-arg index="5" ref="delegate_map_RoomNumberAnnotatorQueue_1"/>
@@ -356,7 +367,7 @@
<!-- Key name -->
<constructor-arg index="1" value="RoomNumber"/>
<constructor-arg index="2"
- value="file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex4/../ex2/RoomNumberAnnotator.xml"/>
+ value="file:/C:/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex4/../ex2/RoomNumberAnnotator.xml"/>
<constructor-arg index="3" ref="casManager"/>
<constructor-arg index="4" ref="inProcessCache"/>
@@ -377,7 +388,7 @@
<!-- Key name -->
<constructor-arg index="1" value="DateTime"/>
<constructor-arg index="2"
- value="file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex4/../ex3/TutorialDateTime.xml"/>
+ value="file:/C:/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex4/../ex3/TutorialDateTime.xml"/>
<constructor-arg index="3" ref="casManager"/>
<constructor-arg index="4" ref="inProcessCache"/>
@@ -398,7 +409,7 @@
<!-- Key name -->
<constructor-arg index="1" value="Meeting"/>
<constructor-arg index="2"
- value="file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex4/MeetingAnnotator.xml"/>
+ value="file:/C:/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex4/MeetingAnnotator.xml"/>
<constructor-arg index="3" ref="casManager"/>
<constructor-arg index="4" ref="inProcessCache"/>
Modified: incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/defaultingPrimAEMultInstance.xml
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/defaultingPrimAEMultInstance.xml?rev=733114&r1=733113&r2=733114&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/defaultingPrimAEMultInstance.xml (original)
+++ incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/defaultingPrimAEMultInstance.xml Fri Jan 9 10:53:30 2009
@@ -1,218 +1,229 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--==================================================================================-->
- <!-- Generated from -->
- <!-- file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/deploy/defaultingPrimAEMultInstance.xml -->
- <!-- 6 October, 2008, 4:40:00 P.M. -->
- <!--==================================================================================-->
- <!DOCTYPE beans
- PUBLIC "-//Spring//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
-<beans>
-
- <!-- Factory for specific external queue broker: -->
- <!-- tcp://localhost:61616 -->
- <bean id="qBroker_tcp_c__ss_localhost_c_61616"
- class="org.apache.activemq.ActiveMQConnectionFactory">
- <property name="brokerURL" value="tcp://localhost:61616"/>
- <property name="prefetchPolicy" ref="prefetchPolicy"/>
- </bean>
-
- <!-- Creates an instance of the ResourceManager -->
- <bean id="resourceManager" class="org.apache.uima.aae.UimaClassFactory"
- factory-method="produceResourceManager"
- singleton="true"/>
-
- <!-- Creates an instance of the CasManager -->
- <bean id="casManager" class="org.apache.uima.aae.AsynchAECasManager_impl"
- singleton="true">
- <constructor-arg index="0" ref="resourceManager"/>
-
- <!-- Defines how many CASes will be in the CAS pool -->
- <property name="casPoolSize" value="40"/>
-
- <!-- Initial heap size for CASes -->
- <property name="initialFsHeapSize" value="2000000"/>
- </bean>
-
- <!-- Creates a Shared Cache -->
- <bean id="inProcessCache" class="org.apache.uima.aae.InProcessCache"/>
-
- <!-- Create prefetch policy -->
- <bean id="prefetchPolicy" class="org.apache.activemq.ActiveMQPrefetchPolicy">
- <property name="queuePrefetch" value="0"/>
- </bean>
-
- <!--=================================-->
- <!-- E r r o r D e t a i l s -->
- <!--=================================-->
- <bean id="errorConfig__TCnt_0_TWndw_0_Action_"
- class="org.apache.uima.aae.error.Threshold"
- singleton="true">
- <property name="threshold" value="0"/>
- <property name="window" value="0"/>
- <property name="action" value=""/>
- </bean>
-
- <bean id="errorConfig__Action_" class="org.apache.uima.aae.error.Threshold"
- singleton="true">
- <property name="action" value=""/>
- </bean>
-
-
- <!--input queue for service-->
- <bean id="top_level_input_queue_service_1"
- class="org.apache.activemq.command.ActiveMQQueue">
- <constructor-arg index="0" value="RoomNumberAnnotatorQueue"/>
- </bean>
- <!--=======================================================-->
- <!-- Primitive or non-Async Aggr: RoomNumberAnnotatorQueue -->
- <!--=======================================================-->
- <bean id="primitive_ctlr_RoomNumberAnnotatorQueue_1"
- class="org.apache.uima.aae.controller.PrimitiveAnalysisEngineController_impl"
- init-method="initialize">
- <constructor-arg index="0">
- <null/>
- </constructor-arg>
-
- <!-- Key name -->
- <constructor-arg index="1" value="RoomNumberAnnotatorQueue"/>
- <constructor-arg index="2"
- value="file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex2/RoomNumberAnnotator.xml"/>
- <constructor-arg index="3" ref="casManager"/>
- <constructor-arg index="4" ref="inProcessCache"/>
-
- <!-- this parameter is ignored -->
- <constructor-arg index="5" value="10"/>
-
- <!-- scaleout number of instances -->
- <constructor-arg index="6" value="40"/>
- <property name="outputChannel" ref="outChnl_RoomNumberAnnotatorQueue_1"/>
- <property name="errorHandlerChain" ref="err_hdlr_chn_RoomNumberAnnotatorQueue_1"/>
- </bean>
-
- <!-- ThreadPool Task Executor -->
- <bean id="pooling_RoomNumberAnnotatorQueue_1"
- class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
- <property name="corePoolSize" value="40"/>
- <property name="maxPoolSize" value="40"/>
- <property name="queueCapacity" value="40"/>
- </bean>
-
- <!--============================================================-->
- <!-- M E S S A G E H A N D L E R: primitive -->
- <!-- for controller: primitive_ctlr_RoomNumberAnnotatorQueue_1 -->
- <!--============================================================-->
-
- <bean id="primitive_metaMsgHandler_RoomNumberAnnotatorQueue_1"
- class="org.apache.uima.aae.handler.input.MetadataRequestHandler_impl">
- <constructor-arg index="0" value="MetadataRequestHandler"/>
- <property name="controller" ref="primitive_ctlr_RoomNumberAnnotatorQueue_1"/>
- <property name="delegate"
- ref="primitive_processRequestHandler_RoomNumberAnnotatorQueue_1"/>
- </bean>
-
- <bean id="primitive_processRequestHandler_RoomNumberAnnotatorQueue_1"
- class="org.apache.uima.aae.handler.input.ProcessRequestHandler_impl">
- <constructor-arg index="0" value="ProcessRequestHandler"/>
- <property name="controller" ref="primitive_ctlr_RoomNumberAnnotatorQueue_1"/>
- </bean>
-
- <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
- <!-- JMS msg listener for input queue for: -->
- <!-- top_level_input_queue_service_1 -->
- <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
- <bean id="primitive_input_q_listenerID_RoomNumberAnnotatorQueue_1"
- class="org.apache.uima.adapter.jms.activemq.JmsInputChannel">
- <property name="messageHandler" ref="primitive_metaMsgHandler_RoomNumberAnnotatorQueue_1"/>
- <property name="endpointName" value="top_level_input_queue_service_1"/>
- <property name="controller" ref="primitive_ctlr_RoomNumberAnnotatorQueue_1"/>
- <property name="listenerContainer"
- ref="primitive_input_msgLsnrCntnr_RoomNumberAnnotatorQueue_1"/>
- </bean>
-
- <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
- <!-- JMS msg listener container for input queue for: -->
- <!-- top_level_input_queue_service_1 -->
- <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
- <bean id="primitive_input_msgLsnrCntnr_RoomNumberAnnotatorQueue_1"
- class="org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer">
-
- <!-- Connect to pooling task executor for primitive -->
- <property name="taskExecutor" ref="pooling_RoomNumberAnnotatorQueue_1"/>
-
- <!-- Define number of JMS Consumers -->
- <property name="concurrentConsumers" value="40"/>
-
- <!-- input Queue -->
- <property name="destination" ref="top_level_input_queue_service_1"/>
-
- <!-- POJO to delegate JMS Messages to -->
- <property name="messageListener"
- ref="primitive_input_q_listenerID_RoomNumberAnnotatorQueue_1"/>
- <property name="connectionFactory" ref="qBroker_tcp_c__ss_localhost_c_61616"/>
- <property name="messageSelector" value="Command=2000 OR Command=2002"/>
- </bean>
-
- <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
- <!-- GetMeta JMS msg listener container for input queue for: -->
- <!-- top_level_input_queue_service_1 -->
- <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
- <bean id="primitive_input_msgLsnrCntnr_RoomNumberAnnotatorQueue_1_getMeta"
- class="org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer">
-
- <!-- Define number of JMS Consumers -->
- <property name="concurrentConsumers" value="1"/>
-
- <!-- input Queue -->
- <property name="destination" ref="top_level_input_queue_service_1"/>
-
- <!-- POJO to delegate JMS Messages to -->
- <property name="messageListener"
- ref="primitive_input_q_listenerID_RoomNumberAnnotatorQueue_1"/>
- <property name="connectionFactory" ref="qBroker_tcp_c__ss_localhost_c_61616"/>
- <property name="messageSelector" value="Command=2001"/>
- </bean>
-
- <!-- ================================== -->
- <!-- OutputChannel - for flows out of -->
- <!-- this component, both to delegates -->
- <!-- (if aggr) and back up to sender -->
- <!-- ================================== -->
- <bean id="outChnl_RoomNumberAnnotatorQueue_1"
- class="org.apache.uima.adapter.jms.activemq.JmsOutputChannel"
- init-method="initialize">
- <property name="serviceInputEndpoint" value="RoomNumberAnnotatorQueue"/>
- <property name="controller" ref="primitive_ctlr_RoomNumberAnnotatorQueue_1"/>
- </bean>
- <bean id="err_hndlr_processCasEr_"
- class="org.apache.uima.aae.error.handler.ProcessCasErrorHandler">
- <constructor-arg>
- <map>
- <entry key="">
- <ref bean="errorConfig__TCnt_0_TWndw_0_Action_"/>
- </entry>
- </map>
- </constructor-arg>
- </bean>
- <bean id="err_hndlr_collectionProcessCompleteEr_"
- class="org.apache.uima.aae.error.handler.CpcErrorHandler">
- <constructor-arg>
- <map>
- <entry key="">
- <ref bean="errorConfig__Action_"/>
- </entry>
- </map>
- </constructor-arg>
- </bean>
- <!--=======================-->
- <!-- Error Handler Chain -->
- <!--=======================-->
- <bean id="err_hdlr_chn_RoomNumberAnnotatorQueue_1"
- class="org.apache.uima.aae.error.ErrorHandlerChain">
- <constructor-arg>
- <list>
- <ref local="err_hndlr_processCasEr_"/>
- <ref local="err_hndlr_collectionProcessCompleteEr_"/>
- </list>
- </constructor-arg>
- </bean>
+<?xml version="1.0" encoding="UTF-8"?>
+<!--==================================================================================-->
+ <!-- Generated from -->
+ <!-- file:/C:/apache/uima-as-distr/src/test/resources/deploy/defaultingPrimAEMultInstance.xml -->
+ <!-- 9 January, 2009, 1:45:47 P.M. -->
+ <!--==================================================================================-->
+ <!DOCTYPE beans
+ PUBLIC "-//Spring//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
+<beans>
+
+ <!-- Factory for specific external queue broker: -->
+ <!-- tcp://localhost:61616 -->
+ <bean id="qBroker_tcp_c__ss_localhost_c_61616"
+ class="org.apache.activemq.ActiveMQConnectionFactory">
+ <property name="brokerURL" value="tcp://localhost:61616"/>
+ <property name="prefetchPolicy" ref="prefetchPolicy"/>
+ </bean>
+
+ <!-- Factory for specific external queue broker: -->
+ <!-- tcp://localhost:61616 -->
+ <bean id="qBroker_tcp_c__ss_localhost_c_61616-reply"
+ class="org.apache.activemq.ActiveMQConnectionFactory">
+ <property name="brokerURL" value="tcp://localhost:61616"/>
+ <property name="prefetchPolicy" ref="prefetchPolicy-reply"/>
+ </bean>
+
+ <!-- Creates an instance of the ResourceManager -->
+ <bean id="resourceManager" class="org.apache.uima.aae.UimaClassFactory"
+ factory-method="produceResourceManager"
+ singleton="true"/>
+
+ <!-- Creates an instance of the CasManager -->
+ <bean id="casManager" class="org.apache.uima.aae.AsynchAECasManager_impl"
+ singleton="true">
+ <constructor-arg index="0" ref="resourceManager"/>
+
+ <!-- Defines how many CASes will be in the CAS pool -->
+ <property name="casPoolSize" value="40"/>
+
+ <!-- Initial heap size for CASes -->
+ <property name="initialFsHeapSize" value="2000000"/>
+ </bean>
+
+ <!-- Creates a Shared Cache -->
+ <bean id="inProcessCache" class="org.apache.uima.aae.InProcessCache"/>
+
+ <!-- Create prefetch policy -->
+ <bean id="prefetchPolicy" class="org.apache.activemq.ActiveMQPrefetchPolicy">
+ <property name="queuePrefetch" value="0"/>
+ </bean>
+ <bean id="prefetchPolicy-reply" class="org.apache.activemq.ActiveMQPrefetchPolicy">
+ <property name="queuePrefetch" value="1"/>
+ </bean>
+
+ <!--=================================-->
+ <!-- E r r o r D e t a i l s -->
+ <!--=================================-->
+ <bean id="errorConfig__TCnt_0_TWndw_0_Action_"
+ class="org.apache.uima.aae.error.Threshold"
+ singleton="true">
+ <property name="threshold" value="0"/>
+ <property name="window" value="0"/>
+ <property name="action" value=""/>
+ </bean>
+
+ <bean id="errorConfig__Action_" class="org.apache.uima.aae.error.Threshold"
+ singleton="true">
+ <property name="action" value=""/>
+ </bean>
+
+
+ <!--input queue for service-->
+ <bean id="top_level_input_queue_service_1"
+ class="org.apache.activemq.command.ActiveMQQueue">
+ <constructor-arg index="0" value="RoomNumberAnnotatorQueue"/>
+ </bean>
+ <!--=======================================================-->
+ <!-- Primitive or non-Async Aggr: RoomNumberAnnotatorQueue -->
+ <!--=======================================================-->
+ <bean id="primitive_ctlr_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.aae.controller.PrimitiveAnalysisEngineController_impl"
+ init-method="initialize">
+ <constructor-arg index="0">
+ <null/>
+ </constructor-arg>
+
+ <!-- Key name -->
+ <constructor-arg index="1" value="RoomNumberAnnotatorQueue"/>
+ <constructor-arg index="2"
+ value="file:/C:/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex2/RoomNumberAnnotator.xml"/>
+ <constructor-arg index="3" ref="casManager"/>
+ <constructor-arg index="4" ref="inProcessCache"/>
+
+ <!-- this parameter is ignored -->
+ <constructor-arg index="5" value="10"/>
+
+ <!-- scaleout number of instances -->
+ <constructor-arg index="6" value="40"/>
+ <property name="outputChannel" ref="outChnl_RoomNumberAnnotatorQueue_1"/>
+ <property name="errorHandlerChain" ref="err_hdlr_chn_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <!-- ThreadPool Task Executor -->
+ <bean id="pooling_RoomNumberAnnotatorQueue_1"
+ class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
+ <property name="corePoolSize" value="40"/>
+ <property name="maxPoolSize" value="40"/>
+ <property name="queueCapacity" value="40"/>
+ </bean>
+
+ <!--============================================================-->
+ <!-- M E S S A G E H A N D L E R: primitive -->
+ <!-- for controller: primitive_ctlr_RoomNumberAnnotatorQueue_1 -->
+ <!--============================================================-->
+
+ <bean id="primitive_metaMsgHandler_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.aae.handler.input.MetadataRequestHandler_impl">
+ <constructor-arg index="0" value="MetadataRequestHandler"/>
+ <property name="controller" ref="primitive_ctlr_RoomNumberAnnotatorQueue_1"/>
+ <property name="delegate"
+ ref="primitive_processRequestHandler_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <bean id="primitive_processRequestHandler_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.aae.handler.input.ProcessRequestHandler_impl">
+ <constructor-arg index="0" value="ProcessRequestHandler"/>
+ <property name="controller" ref="primitive_ctlr_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener for input queue for: -->
+ <!-- top_level_input_queue_service_1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_q_listenerID_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.adapter.jms.activemq.JmsInputChannel">
+ <property name="messageHandler" ref="primitive_metaMsgHandler_RoomNumberAnnotatorQueue_1"/>
+ <property name="endpointName" value="top_level_input_queue_service_1"/>
+ <property name="controller" ref="primitive_ctlr_RoomNumberAnnotatorQueue_1"/>
+ <property name="listenerContainer"
+ ref="primitive_input_msgLsnrCntnr_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener container for input queue for: -->
+ <!-- top_level_input_queue_service_1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_msgLsnrCntnr_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer">
+
+ <!-- Connect to pooling task executor for primitive -->
+ <property name="taskExecutor" ref="pooling_RoomNumberAnnotatorQueue_1"/>
+
+ <!-- Define number of JMS Consumers -->
+ <property name="concurrentConsumers" value="40"/>
+
+ <!-- input Queue -->
+ <property name="destination" ref="top_level_input_queue_service_1"/>
+
+ <!-- POJO to delegate JMS Messages to -->
+ <property name="messageListener"
+ ref="primitive_input_q_listenerID_RoomNumberAnnotatorQueue_1"/>
+ <property name="connectionFactory" ref="qBroker_tcp_c__ss_localhost_c_61616"/>
+ <property name="messageSelector" value="Command=2000 OR Command=2002"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- GetMeta JMS msg listener container for input queue for: -->
+ <!-- top_level_input_queue_service_1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_msgLsnrCntnr_RoomNumberAnnotatorQueue_1_getMeta"
+ class="org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer">
+
+ <!-- Define number of JMS Consumers -->
+ <property name="concurrentConsumers" value="1"/>
+
+ <!-- input Queue -->
+ <property name="destination" ref="top_level_input_queue_service_1"/>
+
+ <!-- POJO to delegate JMS Messages to -->
+ <property name="messageListener"
+ ref="primitive_input_q_listenerID_RoomNumberAnnotatorQueue_1"/>
+ <property name="connectionFactory" ref="qBroker_tcp_c__ss_localhost_c_61616"/>
+ <property name="messageSelector" value="Command=2001"/>
+ </bean>
+
+ <!-- ================================== -->
+ <!-- OutputChannel - for flows out of -->
+ <!-- this component, both to delegates -->
+ <!-- (if aggr) and back up to sender -->
+ <!-- ================================== -->
+ <bean id="outChnl_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.adapter.jms.activemq.JmsOutputChannel"
+ init-method="initialize">
+ <property name="serviceInputEndpoint" value="RoomNumberAnnotatorQueue"/>
+ <property name="controller" ref="primitive_ctlr_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+ <bean id="err_hndlr_processCasEr_"
+ class="org.apache.uima.aae.error.handler.ProcessCasErrorHandler">
+ <constructor-arg>
+ <map>
+ <entry key="">
+ <ref bean="errorConfig__TCnt_0_TWndw_0_Action_"/>
+ </entry>
+ </map>
+ </constructor-arg>
+ </bean>
+ <bean id="err_hndlr_collectionProcessCompleteEr_"
+ class="org.apache.uima.aae.error.handler.CpcErrorHandler">
+ <constructor-arg>
+ <map>
+ <entry key="">
+ <ref bean="errorConfig__Action_"/>
+ </entry>
+ </map>
+ </constructor-arg>
+ </bean>
+ <!--=======================-->
+ <!-- Error Handler Chain -->
+ <!--=======================-->
+ <bean id="err_hdlr_chn_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.aae.error.ErrorHandlerChain">
+ <constructor-arg>
+ <list>
+ <ref local="err_hndlr_processCasEr_"/>
+ <ref local="err_hndlr_collectionProcessCompleteEr_"/>
+ </list>
+ </constructor-arg>
+ </bean>
</beans>
\ No newline at end of file
Modified: incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/envVar/envVarCPP.xml
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/envVar/envVarCPP.xml?rev=733114&r1=733113&r2=733114&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/envVar/envVarCPP.xml (original)
+++ incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/envVar/envVarCPP.xml Fri Jan 9 10:53:30 2009
@@ -1,9 +1,9 @@
<?xml version="1.0" encoding="UTF-8"?>
-<!--==================================================================================-->
- <!-- Generated from -->
- <!-- file:/C:/a/Eclipse/3.3/apache/uima-as-distr/src/test/resources/deploy/envVar/envVarCPP.xml -->
- <!-- 2 November, 2007, 3:01:02 P.M. -->
- <!--==================================================================================-->
+<!--==============================================================================-->
+ <!-- Generated from -->
+ <!-- file:/C:/apache/uima-as-distr/src/test/resources/deploy/envVar/envVarCPP.xml -->
+ <!-- 9 January, 2009, 1:45:11 P.M. -->
+ <!--==============================================================================-->
<!DOCTYPE beans
PUBLIC "-//Spring//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
@@ -15,7 +15,7 @@
<!-- path to top level descriptor -->
<constructor-arg index="0"
- value="file:/C:/a/Eclipse/3.3/apache/uima-as-distr/src/test/resources/deploy/envVar/cppDescr.xml"/>
+ value="file:/C:/apache/uima-as-distr/src/test/resources/deploy/envVar/cppDescr.xml"/>
<!-- input q name -->
<constructor-arg index="1" value="MeetingDetectorTaeQueue"/>
Modified: incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/envVar/envVarCPP1.xml
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/envVar/envVarCPP1.xml?rev=733114&r1=733113&r2=733114&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/envVar/envVarCPP1.xml (original)
+++ incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/envVar/envVarCPP1.xml Fri Jan 9 10:53:30 2009
@@ -1,9 +1,9 @@
<?xml version="1.0" encoding="UTF-8"?>
-<!--==================================================================================-->
- <!-- Generated from -->
- <!-- file:/C:/a/Eclipse/3.3/apache/uima-as-distr/src/test/resources/deploy/envVar/envVarCPP1.xml -->
- <!-- 2 November, 2007, 3:01:04 P.M. -->
- <!--==================================================================================-->
+<!--===============================================================================-->
+ <!-- Generated from -->
+ <!-- file:/C:/apache/uima-as-distr/src/test/resources/deploy/envVar/envVarCPP1.xml -->
+ <!-- 9 January, 2009, 1:45:14 P.M. -->
+ <!--===============================================================================-->
<!DOCTYPE beans
PUBLIC "-//Spring//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
@@ -18,7 +18,7 @@
<!-- path to top level descriptor -->
<constructor-arg index="0"
- value="file:/C:/a/Eclipse/3.3/apache/uima-as-distr/src/test/resources/deploy/envVar/cppDescr.xml"/>
+ value="file:/C:/apache/uima-as-distr/src/test/resources/deploy/envVar/cppDescr.xml"/>
<!-- input q name -->
<constructor-arg index="1" value="MeetingDetectorTaeQueue"/>
Modified: incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/envVar/envVarCPPwrongProtocol.xml
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/envVar/envVarCPPwrongProtocol.xml?rev=733114&r1=733113&r2=733114&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/envVar/envVarCPPwrongProtocol.xml (original)
+++ incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/envVar/envVarCPPwrongProtocol.xml Fri Jan 9 10:53:30 2009
@@ -1,8 +1,8 @@
<?xml version="1.0" encoding="UTF-8"?>
<!--==================================================================================-->
- <!-- Generated from -->
- <!-- file:/C:/a/Eclipse/3.3/apache/uima-as-distr/src/test/resources/deploy/envVar/envVarCPPwrongProtocol.xml -->
- <!-- 2 November, 2007, 3:01:05 P.M. -->
+ <!-- Generated from -->
+ <!-- file:/C:/apache/uima-as-distr/src/test/resources/deploy/envVar/envVarCPPwrongProtocol.xml -->
+ <!-- 9 January, 2009, 1:45:17 P.M. -->
<!--==================================================================================-->
<!DOCTYPE beans
PUBLIC "-//Spring//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
@@ -15,7 +15,7 @@
<!-- path to top level descriptor -->
<constructor-arg index="0"
- value="file:/C:/a/Eclipse/3.3/apache/uima-as-distr/src/test/resources/deploy/envVar/cppDescr.xml"/>
+ value="file:/C:/apache/uima-as-distr/src/test/resources/deploy/envVar/cppDescr.xml"/>
<!-- input q name -->
<constructor-arg index="1" value="MeetingDetectorTaeQueue"/>