You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by sc...@apache.org on 2008/08/25 23:00:15 UTC
svn commit: r688880 [2/3] - in
/incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src: main/scripts/
test/java/org/apache/uima/as/dd/ test/resources/deploy/
test/resources/deploy/expected/ test/resources/deploy/expected/envVar/
test/resources/descript...
Added: incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq2AE.xml
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq2AE.xml?rev=688880&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq2AE.xml (added)
+++ incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq2AE.xml Mon Aug 25 14:00:14 2008
@@ -0,0 +1,218 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--=============================================================================-->
+ <!-- Generated from -->
+ <!-- file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/deploy/iq1AE.xml -->
+ <!-- 25 August, 2008, 1:56:17 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="5"/>
+
+ <!-- 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="1"/>
+ <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="1"/>
+ <property name="maxPoolSize" value="1"/>
+ <property name="queueCapacity" value="1"/>
+ </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="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=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
Added: incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq2AEg.xml
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq2AEg.xml?rev=688880&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq2AEg.xml (added)
+++ incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq2AEg.xml Mon Aug 25 14:00:14 2008
@@ -0,0 +1,793 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--==============================================================================-->
+ <!-- Generated from -->
+ <!-- file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/deploy/iq2AEg.xml -->
+ <!-- 25 August, 2008, 4:01:49 P.M. -->
+ <!--==============================================================================-->
+ <!DOCTYPE beans
+ PUBLIC "-//Spring//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
+<beans>
+
+ <!-- connection factory for co-located things -->
+ <bean id="controllerJmsFactory" class="org.apache.activemq.ActiveMQConnectionFactory"
+ depends-on="brokerDeployerService">
+ <property name="brokerURL" value="vm://localhost"/>
+ <property name="prefetchPolicy" ref="prefetchPolicy"/>
+ </bean>
+
+ <!-- Deploys a co-located broker -->
+ <bean id="brokerDeployerService"
+ class="org.apache.uima.adapter.jms.activemq.BrokerDeployer">
+ <constructor-arg index="0" value="1048576000"/>
+ </bean>
+
+ <!-- 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="5"/>
+
+ <!-- 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>
+
+
+ <!--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>
+ <!--=============================================-->
+ <!-- Async Aggregate: RoomNumberAnnotatorQueue_1 -->
+ <!--=============================================-->
+ <bean id="asAggr_ctlr_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.aae.controller.AggregateAnalysisEngineController_impl"
+ init-method="initialize">
+ <constructor-arg index="0">
+ <null/>
+ </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"/>
+ <constructor-arg index="3" ref="casManager"/>
+ <constructor-arg index="4" ref="inProcessCache"/>
+ <constructor-arg index="5" ref="delegate_map_RoomNumberAnnotatorQueue_1"/>
+ <property name="outputChannel" ref="outChnl_RoomNumberAnnotatorQueue_1"/>
+ <property name="serviceEndpointName" value="top_level_input_queue_service_1"/>
+ <property name="controllerBeanName" value="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ <property name="errorHandlerChain" ref="err_hdlr_chn_RoomNumberAnnotatorQueue_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_RoomNumberAnnotatorQueue_1 -->
+ <!--=========================================================-->
+
+ <bean id="aggregate_input_metaMsgHandler_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.aae.handler.input.MetadataRequestHandler_impl">
+ <constructor-arg index="0" value="MetadataRequestHandler"/>
+ <property name="controller" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ <property name="delegate"
+ ref="aggregate_input_processRequestHandler_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <bean id="aggregate_input_processRequestHandler_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.aae.handler.input.ProcessRequestHandler_impl">
+ <constructor-arg index="0" value="ProcessRequestHandler"/>
+ <property name="controller" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <!--=========================================================-->
+ <!-- M E S S A G E H A N D L E R: aggregate_return -->
+ <!-- for controller: asAggr_ctlr_RoomNumberAnnotatorQueue_1 -->
+ <!--=========================================================-->
+
+ <bean id="aggregate_return_metaMsgHandler_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.aae.handler.input.MetadataRequestHandler_impl">
+ <constructor-arg index="0" value="MetadataRequestHandler"/>
+ <property name="controller" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ <property name="delegate"
+ ref="aggregate_return_processRequestHandler_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <bean id="aggregate_return_processRequestHandler_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.aae.handler.input.ProcessRequestHandler_impl">
+ <constructor-arg index="0" value="ProcessRequestHandler"/>
+ <property name="controller" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ <property name="delegate"
+ ref="aggregate_return_processResponseHandler_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <bean id="aggregate_return_processResponseHandler_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.aae.handler.input.ProcessResponseHandler">
+ <constructor-arg index="0" value="ProcessResponseHandler"/>
+ <property name="controller" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ <property name="delegate"
+ ref="aggregate_return_response_metaMsgHandler_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <bean id="aggregate_return_response_metaMsgHandler_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.aae.handler.input.MetadataResponseHandler_impl">
+ <constructor-arg index="0" value="MetadataResponseHandler"/>
+ <property name="controller" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <!-- Create the endpoints + output channels, one per delegate -->
+
+
+ <!-- ==================================== -->
+ <!-- RoomNumber -->
+ <!-- ** Delegate Endpoint ** -->
+ <!-- ==================================== -->
+ <bean id="endpt_RoomNumber_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_RoomNumber_1.1"/>
+
+ <!-- Timeouts -->
+ <property name="metadataRequestTimeout" value="60000"/>
+ <property name="processRequestTimeout" value="0"/>
+ <property name="collectionProcessCompleteTimeout" value="0"/>
+ <property name="tempReplyDestination" value="true"/>
+ </bean>
+
+ <!-- ==================================== -->
+ <!-- DateTime -->
+ <!-- ** Delegate Endpoint ** -->
+ <!-- ==================================== -->
+ <bean id="endpt_DateTime_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_DateTime_1.2"/>
+
+ <!-- Timeouts -->
+ <property name="metadataRequestTimeout" value="60000"/>
+ <property name="processRequestTimeout" value="0"/>
+ <property name="collectionProcessCompleteTimeout" value="0"/>
+ <property name="tempReplyDestination" value="true"/>
+ </bean>
+
+ <!-- ==================================== -->
+ <!-- Meeting -->
+ <!-- ** Delegate Endpoint ** -->
+ <!-- ==================================== -->
+ <bean id="endpt_Meeting_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_Meeting_1.3"/>
+
+ <!-- Timeouts -->
+ <property name="metadataRequestTimeout" value="60000"/>
+ <property name="processRequestTimeout" value="0"/>
+ <property name="collectionProcessCompleteTimeout" value="0"/>
+ <property name="tempReplyDestination" value="true"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener for input queue for: -->
+ <!-- top_level_input_queue_service_1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="asAggr_input_q_listenerID_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.adapter.jms.activemq.JmsInputChannel">
+ <property name="messageHandler"
+ ref="aggregate_input_metaMsgHandler_RoomNumberAnnotatorQueue_1"/>
+ <property name="endpointName" value="top_level_input_queue_service_1"/>
+ <property name="controller" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ <property name="listenerContainer"
+ ref="asAggr_input_msgLsnrCntnr_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener container for input queue for: -->
+ <!-- top_level_input_queue_service_1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="asAggr_input_msgLsnrCntnr_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer">
+
+ <!-- Define number of JMS Consumers -->
+ <property name="concurrentConsumers" value="34"/>
+
+ <!-- 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_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="asAggr_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="asAggr_input_q_listenerID_RoomNumberAnnotatorQueue_1"/>
+ <property name="connectionFactory" ref="qBroker_tcp_c__ss_localhost_c_61616"/>
+ <property name="messageSelector" value="Command=2001"/>
+ </bean>
+
+ <!-- return queue for async aggregate -->
+ <bean id="asynAggr_retQ_RoomNumberAnnotatorQueue_1"
+ class="org.apache.activemq.command.ActiveMQQueue">
+ <constructor-arg index="0" value="asynAggr_retQ_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~-->
+ <!-- JMS msg listener for return queue for: -->
+ <!-- asynAggr_retQ_RoomNumberAnnotatorQueue_1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~-->
+ <bean id="asAggr_return_q_listenerID_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.adapter.jms.activemq.JmsInputChannel">
+ <property name="messageHandler"
+ ref="aggregate_return_metaMsgHandler_RoomNumberAnnotatorQueue_1"/>
+ <property name="endpointName" value="asynAggr_retQ_RoomNumberAnnotatorQueue_1"/>
+ <property name="controller" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~-->
+ <!-- JMS msg listener container for return queue for: -->
+ <!-- asynAggr_retQ_RoomNumberAnnotatorQueue_1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~-->
+ <bean id="asAggr_return_msgLsnrCntnr_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer">
+
+ <!-- Define number of JMS Consumers -->
+ <property name="concurrentConsumers" value="1"/>
+
+ <!-- return Queue -->
+ <property name="destination" ref="asynAggr_retQ_RoomNumberAnnotatorQueue_1"/>
+
+ <!-- POJO to delegate JMS Messages to -->
+ <property name="messageListener"
+ ref="asAggr_return_q_listenerID_RoomNumberAnnotatorQueue_1"/>
+ <property name="connectionFactory" ref="controllerJmsFactory"/>
+ </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="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ <property name="controllerInputEndpoint" value="asynAggr_retQ_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <!-- map for delegate keys -->
+ <bean id="delegate_map_RoomNumberAnnotatorQueue_1" class="java.util.HashMap"
+ singleton="true">
+ <constructor-arg>
+ <map>
+ <entry key="RoomNumber">
+ <ref bean="endpt_RoomNumber_1.1"/>
+ </entry>
+ <entry key="DateTime">
+ <ref bean="endpt_DateTime_1.2"/>
+ </entry>
+ <entry key="Meeting">
+ <ref bean="endpt_Meeting_1.3"/>
+ </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="RoomNumber">
+ <ref bean="errorConfig__Rtry_0_Action_terminate"/>
+ </entry>
+ <entry key="DateTime">
+ <ref bean="errorConfig__Rtry_0_Action_terminate"/>
+ </entry>
+ <entry key="Meeting">
+ <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="RoomNumber">
+ <ref bean="errorConfig__Rtry_0_Continue_false_TCnt_0_TWndw_0_Action_"/>
+ </entry>
+ <entry key="DateTime">
+ <ref bean="errorConfig__Rtry_0_Continue_false_TCnt_0_TWndw_0_Action_"/>
+ </entry>
+ <entry key="Meeting">
+ <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="RoomNumber">
+ <ref bean="errorConfig__Action_"/>
+ </entry>
+ <entry key="DateTime">
+ <ref bean="errorConfig__Action_"/>
+ </entry>
+ <entry key="Meeting">
+ <ref bean="errorConfig__Action_"/>
+ </entry>
+ <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_getMetadataEr_1"/>
+ <ref local="err_hndlr_processCasEr_1"/>
+ <ref local="err_hndlr_collectionProcessCompleteEr_1"/>
+ </list>
+ </constructor-arg>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- Internal Input Queue for -->
+ <!-- RoomNumber -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="inQ_RoomNumber_1.1" class="org.apache.activemq.command.ActiveMQQueue">
+ <constructor-arg index="0" value="inQ_RoomNumber_1.1"/>
+ </bean>
+ <!--=========================================-->
+ <!-- Primitive or non-Async Aggr: RoomNumber -->
+ <!--=========================================-->
+ <bean id="primitive_ctlr_RoomNumber_1.1"
+ class="org.apache.uima.aae.controller.PrimitiveAnalysisEngineController_impl"
+ init-method="initialize">
+ <constructor-arg index="0" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+
+ <!-- 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"/>
+ <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"/>
+ <property name="outputChannel" ref="outChnl_RoomNumber_1.1"/>
+ </bean>
+
+ <!-- ThreadPool Task Executor -->
+ <bean id="pooling_RoomNumber_1.1"
+ class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
+ <property name="corePoolSize" value="1"/>
+ <property name="maxPoolSize" value="1"/>
+ <property name="queueCapacity" value="1"/>
+ </bean>
+
+ <!--================================================-->
+ <!-- M E S S A G E H A N D L E R: primitive -->
+ <!-- for controller: primitive_ctlr_RoomNumber_1.1 -->
+ <!--================================================-->
+
+ <bean id="primitive_metaMsgHandler_RoomNumber_1.1"
+ class="org.apache.uima.aae.handler.input.MetadataRequestHandler_impl">
+ <constructor-arg index="0" value="MetadataRequestHandler"/>
+ <property name="controller" ref="primitive_ctlr_RoomNumber_1.1"/>
+ <property name="delegate" ref="primitive_processRequestHandler_RoomNumber_1.1"/>
+ </bean>
+
+ <bean id="primitive_processRequestHandler_RoomNumber_1.1"
+ class="org.apache.uima.aae.handler.input.ProcessRequestHandler_impl">
+ <constructor-arg index="0" value="ProcessRequestHandler"/>
+ <property name="controller" ref="primitive_ctlr_RoomNumber_1.1"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener for input queue for: -->
+ <!-- inQ_RoomNumber_1.1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_q_listenerID_RoomNumber_1.1"
+ class="org.apache.uima.adapter.jms.activemq.JmsInputChannel">
+ <property name="messageHandler" ref="primitive_metaMsgHandler_RoomNumber_1.1"/>
+ <property name="endpointName" value="inQ_RoomNumber_1.1"/>
+ <property name="controller" ref="primitive_ctlr_RoomNumber_1.1"/>
+ <property name="listenerContainer" ref="primitive_input_msgLsnrCntnr_RoomNumber_1.1"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener container for input queue for: -->
+ <!-- inQ_RoomNumber_1.1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_msgLsnrCntnr_RoomNumber_1.1"
+ class="org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer">
+
+ <!-- Connect to pooling task executor for primitive -->
+ <property name="taskExecutor" ref="pooling_RoomNumber_1.1"/>
+
+ <!-- Define number of JMS Consumers -->
+ <property name="concurrentConsumers" value="1"/>
+
+ <!-- input Queue -->
+ <property name="destination" ref="inQ_RoomNumber_1.1"/>
+
+ <!-- POJO to delegate JMS Messages to -->
+ <property name="messageListener" ref="primitive_input_q_listenerID_RoomNumber_1.1"/>
+ <property name="connectionFactory" ref="controllerJmsFactory"/>
+ <property name="messageSelector" value="Command=2000 OR Command=2002"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- GetMeta JMS msg listener container for input queue for: -->
+ <!-- inQ_RoomNumber_1.1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_msgLsnrCntnr_RoomNumber_1.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="inQ_RoomNumber_1.1"/>
+
+ <!-- POJO to delegate JMS Messages to -->
+ <property name="messageListener" ref="primitive_input_q_listenerID_RoomNumber_1.1"/>
+ <property name="connectionFactory" ref="controllerJmsFactory"/>
+ <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_RoomNumber_1.1"
+ class="org.apache.uima.adapter.jms.activemq.JmsOutputChannel"
+ init-method="initialize">
+ <property name="serviceInputEndpoint" value="inQ_RoomNumber_1.1"/>
+ <property name="controller" ref="primitive_ctlr_RoomNumber_1.1"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- Internal Input Queue for -->
+ <!-- DateTime -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="inQ_DateTime_1.2" class="org.apache.activemq.command.ActiveMQQueue">
+ <constructor-arg index="0" value="inQ_DateTime_1.2"/>
+ </bean>
+ <!--=======================================-->
+ <!-- Primitive or non-Async Aggr: DateTime -->
+ <!--=======================================-->
+ <bean id="primitive_ctlr_DateTime_1.2"
+ class="org.apache.uima.aae.controller.PrimitiveAnalysisEngineController_impl"
+ init-method="initialize">
+ <constructor-arg index="0" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+
+ <!-- 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"/>
+ <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"/>
+ <property name="outputChannel" ref="outChnl_DateTime_1.2"/>
+ </bean>
+
+ <!-- ThreadPool Task Executor -->
+ <bean id="pooling_DateTime_1.2"
+ class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
+ <property name="corePoolSize" value="1"/>
+ <property name="maxPoolSize" value="1"/>
+ <property name="queueCapacity" value="1"/>
+ </bean>
+
+ <!--==============================================-->
+ <!-- M E S S A G E H A N D L E R: primitive -->
+ <!-- for controller: primitive_ctlr_DateTime_1.2 -->
+ <!--==============================================-->
+
+ <bean id="primitive_metaMsgHandler_DateTime_1.2"
+ class="org.apache.uima.aae.handler.input.MetadataRequestHandler_impl">
+ <constructor-arg index="0" value="MetadataRequestHandler"/>
+ <property name="controller" ref="primitive_ctlr_DateTime_1.2"/>
+ <property name="delegate" ref="primitive_processRequestHandler_DateTime_1.2"/>
+ </bean>
+
+ <bean id="primitive_processRequestHandler_DateTime_1.2"
+ class="org.apache.uima.aae.handler.input.ProcessRequestHandler_impl">
+ <constructor-arg index="0" value="ProcessRequestHandler"/>
+ <property name="controller" ref="primitive_ctlr_DateTime_1.2"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener for input queue for: -->
+ <!-- inQ_DateTime_1.2 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_q_listenerID_DateTime_1.2"
+ class="org.apache.uima.adapter.jms.activemq.JmsInputChannel">
+ <property name="messageHandler" ref="primitive_metaMsgHandler_DateTime_1.2"/>
+ <property name="endpointName" value="inQ_DateTime_1.2"/>
+ <property name="controller" ref="primitive_ctlr_DateTime_1.2"/>
+ <property name="listenerContainer" ref="primitive_input_msgLsnrCntnr_DateTime_1.2"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener container for input queue for: -->
+ <!-- inQ_DateTime_1.2 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_msgLsnrCntnr_DateTime_1.2"
+ class="org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer">
+
+ <!-- Connect to pooling task executor for primitive -->
+ <property name="taskExecutor" ref="pooling_DateTime_1.2"/>
+
+ <!-- Define number of JMS Consumers -->
+ <property name="concurrentConsumers" value="1"/>
+
+ <!-- input Queue -->
+ <property name="destination" ref="inQ_DateTime_1.2"/>
+
+ <!-- POJO to delegate JMS Messages to -->
+ <property name="messageListener" ref="primitive_input_q_listenerID_DateTime_1.2"/>
+ <property name="connectionFactory" ref="controllerJmsFactory"/>
+ <property name="messageSelector" value="Command=2000 OR Command=2002"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- GetMeta JMS msg listener container for input queue for: -->
+ <!-- inQ_DateTime_1.2 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_msgLsnrCntnr_DateTime_1.2_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="inQ_DateTime_1.2"/>
+
+ <!-- POJO to delegate JMS Messages to -->
+ <property name="messageListener" ref="primitive_input_q_listenerID_DateTime_1.2"/>
+ <property name="connectionFactory" ref="controllerJmsFactory"/>
+ <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_DateTime_1.2"
+ class="org.apache.uima.adapter.jms.activemq.JmsOutputChannel"
+ init-method="initialize">
+ <property name="serviceInputEndpoint" value="inQ_DateTime_1.2"/>
+ <property name="controller" ref="primitive_ctlr_DateTime_1.2"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- Internal Input Queue for -->
+ <!-- Meeting -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="inQ_Meeting_1.3" class="org.apache.activemq.command.ActiveMQQueue">
+ <constructor-arg index="0" value="inQ_Meeting_1.3"/>
+ </bean>
+ <!--======================================-->
+ <!-- Primitive or non-Async Aggr: Meeting -->
+ <!--======================================-->
+ <bean id="primitive_ctlr_Meeting_1.3"
+ class="org.apache.uima.aae.controller.PrimitiveAnalysisEngineController_impl"
+ init-method="initialize">
+ <constructor-arg index="0" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+
+ <!-- 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"/>
+ <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"/>
+ <property name="outputChannel" ref="outChnl_Meeting_1.3"/>
+ </bean>
+
+ <!-- ThreadPool Task Executor -->
+ <bean id="pooling_Meeting_1.3"
+ class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
+ <property name="corePoolSize" value="1"/>
+ <property name="maxPoolSize" value="1"/>
+ <property name="queueCapacity" value="1"/>
+ </bean>
+
+ <!--=============================================-->
+ <!-- M E S S A G E H A N D L E R: primitive -->
+ <!-- for controller: primitive_ctlr_Meeting_1.3 -->
+ <!--=============================================-->
+
+ <bean id="primitive_metaMsgHandler_Meeting_1.3"
+ class="org.apache.uima.aae.handler.input.MetadataRequestHandler_impl">
+ <constructor-arg index="0" value="MetadataRequestHandler"/>
+ <property name="controller" ref="primitive_ctlr_Meeting_1.3"/>
+ <property name="delegate" ref="primitive_processRequestHandler_Meeting_1.3"/>
+ </bean>
+
+ <bean id="primitive_processRequestHandler_Meeting_1.3"
+ class="org.apache.uima.aae.handler.input.ProcessRequestHandler_impl">
+ <constructor-arg index="0" value="ProcessRequestHandler"/>
+ <property name="controller" ref="primitive_ctlr_Meeting_1.3"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener for input queue for: -->
+ <!-- inQ_Meeting_1.3 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_q_listenerID_Meeting_1.3"
+ class="org.apache.uima.adapter.jms.activemq.JmsInputChannel">
+ <property name="messageHandler" ref="primitive_metaMsgHandler_Meeting_1.3"/>
+ <property name="endpointName" value="inQ_Meeting_1.3"/>
+ <property name="controller" ref="primitive_ctlr_Meeting_1.3"/>
+ <property name="listenerContainer" ref="primitive_input_msgLsnrCntnr_Meeting_1.3"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener container for input queue for: -->
+ <!-- inQ_Meeting_1.3 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_msgLsnrCntnr_Meeting_1.3"
+ class="org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer">
+
+ <!-- Connect to pooling task executor for primitive -->
+ <property name="taskExecutor" ref="pooling_Meeting_1.3"/>
+
+ <!-- Define number of JMS Consumers -->
+ <property name="concurrentConsumers" value="1"/>
+
+ <!-- input Queue -->
+ <property name="destination" ref="inQ_Meeting_1.3"/>
+
+ <!-- POJO to delegate JMS Messages to -->
+ <property name="messageListener" ref="primitive_input_q_listenerID_Meeting_1.3"/>
+ <property name="connectionFactory" ref="controllerJmsFactory"/>
+ <property name="messageSelector" value="Command=2000 OR Command=2002"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- GetMeta JMS msg listener container for input queue for: -->
+ <!-- inQ_Meeting_1.3 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_msgLsnrCntnr_Meeting_1.3_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="inQ_Meeting_1.3"/>
+
+ <!-- POJO to delegate JMS Messages to -->
+ <property name="messageListener" ref="primitive_input_q_listenerID_Meeting_1.3"/>
+ <property name="connectionFactory" ref="controllerJmsFactory"/>
+ <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_Meeting_1.3"
+ class="org.apache.uima.adapter.jms.activemq.JmsOutputChannel"
+ init-method="initialize">
+ <property name="serviceInputEndpoint" value="inQ_Meeting_1.3"/>
+ <property name="controller" ref="primitive_ctlr_Meeting_1.3"/>
+ </bean>
+</beans>
\ No newline at end of file
Added: incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq2AEg2.xml
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq2AEg2.xml?rev=688880&view=auto
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq2AEg2.xml (added)
+++ incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq2AEg2.xml Mon Aug 25 14:00:14 2008
@@ -0,0 +1,793 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--===============================================================================-->
+ <!-- Generated from -->
+ <!-- file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/deploy/iq2AEg2.xml -->
+ <!-- 25 August, 2008, 4:08:44 P.M. -->
+ <!--===============================================================================-->
+ <!DOCTYPE beans
+ PUBLIC "-//Spring//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
+<beans>
+
+ <!-- connection factory for co-located things -->
+ <bean id="controllerJmsFactory" class="org.apache.activemq.ActiveMQConnectionFactory"
+ depends-on="brokerDeployerService">
+ <property name="brokerURL" value="vm://localhost"/>
+ <property name="prefetchPolicy" ref="prefetchPolicy"/>
+ </bean>
+
+ <!-- Deploys a co-located broker -->
+ <bean id="brokerDeployerService"
+ class="org.apache.uima.adapter.jms.activemq.BrokerDeployer">
+ <constructor-arg index="0" value="1048576000"/>
+ </bean>
+
+ <!-- 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="5"/>
+
+ <!-- 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>
+
+
+ <!--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>
+ <!--=============================================-->
+ <!-- Async Aggregate: RoomNumberAnnotatorQueue_1 -->
+ <!--=============================================-->
+ <bean id="asAggr_ctlr_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.aae.controller.AggregateAnalysisEngineController_impl"
+ init-method="initialize">
+ <constructor-arg index="0">
+ <null/>
+ </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"/>
+ <constructor-arg index="3" ref="casManager"/>
+ <constructor-arg index="4" ref="inProcessCache"/>
+ <constructor-arg index="5" ref="delegate_map_RoomNumberAnnotatorQueue_1"/>
+ <property name="outputChannel" ref="outChnl_RoomNumberAnnotatorQueue_1"/>
+ <property name="serviceEndpointName" value="top_level_input_queue_service_1"/>
+ <property name="controllerBeanName" value="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ <property name="errorHandlerChain" ref="err_hdlr_chn_RoomNumberAnnotatorQueue_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_RoomNumberAnnotatorQueue_1 -->
+ <!--=========================================================-->
+
+ <bean id="aggregate_input_metaMsgHandler_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.aae.handler.input.MetadataRequestHandler_impl">
+ <constructor-arg index="0" value="MetadataRequestHandler"/>
+ <property name="controller" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ <property name="delegate"
+ ref="aggregate_input_processRequestHandler_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <bean id="aggregate_input_processRequestHandler_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.aae.handler.input.ProcessRequestHandler_impl">
+ <constructor-arg index="0" value="ProcessRequestHandler"/>
+ <property name="controller" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <!--=========================================================-->
+ <!-- M E S S A G E H A N D L E R: aggregate_return -->
+ <!-- for controller: asAggr_ctlr_RoomNumberAnnotatorQueue_1 -->
+ <!--=========================================================-->
+
+ <bean id="aggregate_return_metaMsgHandler_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.aae.handler.input.MetadataRequestHandler_impl">
+ <constructor-arg index="0" value="MetadataRequestHandler"/>
+ <property name="controller" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ <property name="delegate"
+ ref="aggregate_return_processRequestHandler_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <bean id="aggregate_return_processRequestHandler_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.aae.handler.input.ProcessRequestHandler_impl">
+ <constructor-arg index="0" value="ProcessRequestHandler"/>
+ <property name="controller" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ <property name="delegate"
+ ref="aggregate_return_processResponseHandler_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <bean id="aggregate_return_processResponseHandler_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.aae.handler.input.ProcessResponseHandler">
+ <constructor-arg index="0" value="ProcessResponseHandler"/>
+ <property name="controller" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ <property name="delegate"
+ ref="aggregate_return_response_metaMsgHandler_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <bean id="aggregate_return_response_metaMsgHandler_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.aae.handler.input.MetadataResponseHandler_impl">
+ <constructor-arg index="0" value="MetadataResponseHandler"/>
+ <property name="controller" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <!-- Create the endpoints + output channels, one per delegate -->
+
+
+ <!-- ==================================== -->
+ <!-- RoomNumber -->
+ <!-- ** Delegate Endpoint ** -->
+ <!-- ==================================== -->
+ <bean id="endpt_RoomNumber_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_RoomNumber_1.1"/>
+
+ <!-- Timeouts -->
+ <property name="metadataRequestTimeout" value="60000"/>
+ <property name="processRequestTimeout" value="0"/>
+ <property name="collectionProcessCompleteTimeout" value="0"/>
+ <property name="tempReplyDestination" value="true"/>
+ </bean>
+
+ <!-- ==================================== -->
+ <!-- DateTime -->
+ <!-- ** Delegate Endpoint ** -->
+ <!-- ==================================== -->
+ <bean id="endpt_DateTime_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_DateTime_1.2"/>
+
+ <!-- Timeouts -->
+ <property name="metadataRequestTimeout" value="60000"/>
+ <property name="processRequestTimeout" value="0"/>
+ <property name="collectionProcessCompleteTimeout" value="0"/>
+ <property name="tempReplyDestination" value="true"/>
+ </bean>
+
+ <!-- ==================================== -->
+ <!-- Meeting -->
+ <!-- ** Delegate Endpoint ** -->
+ <!-- ==================================== -->
+ <bean id="endpt_Meeting_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_Meeting_1.3"/>
+
+ <!-- Timeouts -->
+ <property name="metadataRequestTimeout" value="60000"/>
+ <property name="processRequestTimeout" value="0"/>
+ <property name="collectionProcessCompleteTimeout" value="0"/>
+ <property name="tempReplyDestination" value="true"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener for input queue for: -->
+ <!-- top_level_input_queue_service_1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="asAggr_input_q_listenerID_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.adapter.jms.activemq.JmsInputChannel">
+ <property name="messageHandler"
+ ref="aggregate_input_metaMsgHandler_RoomNumberAnnotatorQueue_1"/>
+ <property name="endpointName" value="top_level_input_queue_service_1"/>
+ <property name="controller" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ <property name="listenerContainer"
+ ref="asAggr_input_msgLsnrCntnr_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener container for input queue for: -->
+ <!-- top_level_input_queue_service_1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="asAggr_input_msgLsnrCntnr_RoomNumberAnnotatorQueue_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_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="asAggr_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="asAggr_input_q_listenerID_RoomNumberAnnotatorQueue_1"/>
+ <property name="connectionFactory" ref="qBroker_tcp_c__ss_localhost_c_61616"/>
+ <property name="messageSelector" value="Command=2001"/>
+ </bean>
+
+ <!-- return queue for async aggregate -->
+ <bean id="asynAggr_retQ_RoomNumberAnnotatorQueue_1"
+ class="org.apache.activemq.command.ActiveMQQueue">
+ <constructor-arg index="0" value="asynAggr_retQ_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~-->
+ <!-- JMS msg listener for return queue for: -->
+ <!-- asynAggr_retQ_RoomNumberAnnotatorQueue_1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~-->
+ <bean id="asAggr_return_q_listenerID_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.adapter.jms.activemq.JmsInputChannel">
+ <property name="messageHandler"
+ ref="aggregate_return_metaMsgHandler_RoomNumberAnnotatorQueue_1"/>
+ <property name="endpointName" value="asynAggr_retQ_RoomNumberAnnotatorQueue_1"/>
+ <property name="controller" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~-->
+ <!-- JMS msg listener container for return queue for: -->
+ <!-- asynAggr_retQ_RoomNumberAnnotatorQueue_1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~-->
+ <bean id="asAggr_return_msgLsnrCntnr_RoomNumberAnnotatorQueue_1"
+ class="org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer">
+
+ <!-- Define number of JMS Consumers -->
+ <property name="concurrentConsumers" value="37"/>
+
+ <!-- return Queue -->
+ <property name="destination" ref="asynAggr_retQ_RoomNumberAnnotatorQueue_1"/>
+
+ <!-- POJO to delegate JMS Messages to -->
+ <property name="messageListener"
+ ref="asAggr_return_q_listenerID_RoomNumberAnnotatorQueue_1"/>
+ <property name="connectionFactory" ref="controllerJmsFactory"/>
+ </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="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+ <property name="controllerInputEndpoint" value="asynAggr_retQ_RoomNumberAnnotatorQueue_1"/>
+ </bean>
+
+ <!-- map for delegate keys -->
+ <bean id="delegate_map_RoomNumberAnnotatorQueue_1" class="java.util.HashMap"
+ singleton="true">
+ <constructor-arg>
+ <map>
+ <entry key="RoomNumber">
+ <ref bean="endpt_RoomNumber_1.1"/>
+ </entry>
+ <entry key="DateTime">
+ <ref bean="endpt_DateTime_1.2"/>
+ </entry>
+ <entry key="Meeting">
+ <ref bean="endpt_Meeting_1.3"/>
+ </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="RoomNumber">
+ <ref bean="errorConfig__Rtry_0_Action_terminate"/>
+ </entry>
+ <entry key="DateTime">
+ <ref bean="errorConfig__Rtry_0_Action_terminate"/>
+ </entry>
+ <entry key="Meeting">
+ <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="RoomNumber">
+ <ref bean="errorConfig__Rtry_0_Continue_false_TCnt_0_TWndw_0_Action_"/>
+ </entry>
+ <entry key="DateTime">
+ <ref bean="errorConfig__Rtry_0_Continue_false_TCnt_0_TWndw_0_Action_"/>
+ </entry>
+ <entry key="Meeting">
+ <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="RoomNumber">
+ <ref bean="errorConfig__Action_"/>
+ </entry>
+ <entry key="DateTime">
+ <ref bean="errorConfig__Action_"/>
+ </entry>
+ <entry key="Meeting">
+ <ref bean="errorConfig__Action_"/>
+ </entry>
+ <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_getMetadataEr_1"/>
+ <ref local="err_hndlr_processCasEr_1"/>
+ <ref local="err_hndlr_collectionProcessCompleteEr_1"/>
+ </list>
+ </constructor-arg>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- Internal Input Queue for -->
+ <!-- RoomNumber -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="inQ_RoomNumber_1.1" class="org.apache.activemq.command.ActiveMQQueue">
+ <constructor-arg index="0" value="inQ_RoomNumber_1.1"/>
+ </bean>
+ <!--=========================================-->
+ <!-- Primitive or non-Async Aggr: RoomNumber -->
+ <!--=========================================-->
+ <bean id="primitive_ctlr_RoomNumber_1.1"
+ class="org.apache.uima.aae.controller.PrimitiveAnalysisEngineController_impl"
+ init-method="initialize">
+ <constructor-arg index="0" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+
+ <!-- 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"/>
+ <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"/>
+ <property name="outputChannel" ref="outChnl_RoomNumber_1.1"/>
+ </bean>
+
+ <!-- ThreadPool Task Executor -->
+ <bean id="pooling_RoomNumber_1.1"
+ class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
+ <property name="corePoolSize" value="1"/>
+ <property name="maxPoolSize" value="1"/>
+ <property name="queueCapacity" value="1"/>
+ </bean>
+
+ <!--================================================-->
+ <!-- M E S S A G E H A N D L E R: primitive -->
+ <!-- for controller: primitive_ctlr_RoomNumber_1.1 -->
+ <!--================================================-->
+
+ <bean id="primitive_metaMsgHandler_RoomNumber_1.1"
+ class="org.apache.uima.aae.handler.input.MetadataRequestHandler_impl">
+ <constructor-arg index="0" value="MetadataRequestHandler"/>
+ <property name="controller" ref="primitive_ctlr_RoomNumber_1.1"/>
+ <property name="delegate" ref="primitive_processRequestHandler_RoomNumber_1.1"/>
+ </bean>
+
+ <bean id="primitive_processRequestHandler_RoomNumber_1.1"
+ class="org.apache.uima.aae.handler.input.ProcessRequestHandler_impl">
+ <constructor-arg index="0" value="ProcessRequestHandler"/>
+ <property name="controller" ref="primitive_ctlr_RoomNumber_1.1"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener for input queue for: -->
+ <!-- inQ_RoomNumber_1.1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_q_listenerID_RoomNumber_1.1"
+ class="org.apache.uima.adapter.jms.activemq.JmsInputChannel">
+ <property name="messageHandler" ref="primitive_metaMsgHandler_RoomNumber_1.1"/>
+ <property name="endpointName" value="inQ_RoomNumber_1.1"/>
+ <property name="controller" ref="primitive_ctlr_RoomNumber_1.1"/>
+ <property name="listenerContainer" ref="primitive_input_msgLsnrCntnr_RoomNumber_1.1"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener container for input queue for: -->
+ <!-- inQ_RoomNumber_1.1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_msgLsnrCntnr_RoomNumber_1.1"
+ class="org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer">
+
+ <!-- Connect to pooling task executor for primitive -->
+ <property name="taskExecutor" ref="pooling_RoomNumber_1.1"/>
+
+ <!-- Define number of JMS Consumers -->
+ <property name="concurrentConsumers" value="1"/>
+
+ <!-- input Queue -->
+ <property name="destination" ref="inQ_RoomNumber_1.1"/>
+
+ <!-- POJO to delegate JMS Messages to -->
+ <property name="messageListener" ref="primitive_input_q_listenerID_RoomNumber_1.1"/>
+ <property name="connectionFactory" ref="controllerJmsFactory"/>
+ <property name="messageSelector" value="Command=2000 OR Command=2002"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- GetMeta JMS msg listener container for input queue for: -->
+ <!-- inQ_RoomNumber_1.1 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_msgLsnrCntnr_RoomNumber_1.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="inQ_RoomNumber_1.1"/>
+
+ <!-- POJO to delegate JMS Messages to -->
+ <property name="messageListener" ref="primitive_input_q_listenerID_RoomNumber_1.1"/>
+ <property name="connectionFactory" ref="controllerJmsFactory"/>
+ <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_RoomNumber_1.1"
+ class="org.apache.uima.adapter.jms.activemq.JmsOutputChannel"
+ init-method="initialize">
+ <property name="serviceInputEndpoint" value="inQ_RoomNumber_1.1"/>
+ <property name="controller" ref="primitive_ctlr_RoomNumber_1.1"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- Internal Input Queue for -->
+ <!-- DateTime -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="inQ_DateTime_1.2" class="org.apache.activemq.command.ActiveMQQueue">
+ <constructor-arg index="0" value="inQ_DateTime_1.2"/>
+ </bean>
+ <!--=======================================-->
+ <!-- Primitive or non-Async Aggr: DateTime -->
+ <!--=======================================-->
+ <bean id="primitive_ctlr_DateTime_1.2"
+ class="org.apache.uima.aae.controller.PrimitiveAnalysisEngineController_impl"
+ init-method="initialize">
+ <constructor-arg index="0" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+
+ <!-- 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"/>
+ <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"/>
+ <property name="outputChannel" ref="outChnl_DateTime_1.2"/>
+ </bean>
+
+ <!-- ThreadPool Task Executor -->
+ <bean id="pooling_DateTime_1.2"
+ class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
+ <property name="corePoolSize" value="1"/>
+ <property name="maxPoolSize" value="1"/>
+ <property name="queueCapacity" value="1"/>
+ </bean>
+
+ <!--==============================================-->
+ <!-- M E S S A G E H A N D L E R: primitive -->
+ <!-- for controller: primitive_ctlr_DateTime_1.2 -->
+ <!--==============================================-->
+
+ <bean id="primitive_metaMsgHandler_DateTime_1.2"
+ class="org.apache.uima.aae.handler.input.MetadataRequestHandler_impl">
+ <constructor-arg index="0" value="MetadataRequestHandler"/>
+ <property name="controller" ref="primitive_ctlr_DateTime_1.2"/>
+ <property name="delegate" ref="primitive_processRequestHandler_DateTime_1.2"/>
+ </bean>
+
+ <bean id="primitive_processRequestHandler_DateTime_1.2"
+ class="org.apache.uima.aae.handler.input.ProcessRequestHandler_impl">
+ <constructor-arg index="0" value="ProcessRequestHandler"/>
+ <property name="controller" ref="primitive_ctlr_DateTime_1.2"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener for input queue for: -->
+ <!-- inQ_DateTime_1.2 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_q_listenerID_DateTime_1.2"
+ class="org.apache.uima.adapter.jms.activemq.JmsInputChannel">
+ <property name="messageHandler" ref="primitive_metaMsgHandler_DateTime_1.2"/>
+ <property name="endpointName" value="inQ_DateTime_1.2"/>
+ <property name="controller" ref="primitive_ctlr_DateTime_1.2"/>
+ <property name="listenerContainer" ref="primitive_input_msgLsnrCntnr_DateTime_1.2"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener container for input queue for: -->
+ <!-- inQ_DateTime_1.2 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_msgLsnrCntnr_DateTime_1.2"
+ class="org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer">
+
+ <!-- Connect to pooling task executor for primitive -->
+ <property name="taskExecutor" ref="pooling_DateTime_1.2"/>
+
+ <!-- Define number of JMS Consumers -->
+ <property name="concurrentConsumers" value="1"/>
+
+ <!-- input Queue -->
+ <property name="destination" ref="inQ_DateTime_1.2"/>
+
+ <!-- POJO to delegate JMS Messages to -->
+ <property name="messageListener" ref="primitive_input_q_listenerID_DateTime_1.2"/>
+ <property name="connectionFactory" ref="controllerJmsFactory"/>
+ <property name="messageSelector" value="Command=2000 OR Command=2002"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- GetMeta JMS msg listener container for input queue for: -->
+ <!-- inQ_DateTime_1.2 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_msgLsnrCntnr_DateTime_1.2_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="inQ_DateTime_1.2"/>
+
+ <!-- POJO to delegate JMS Messages to -->
+ <property name="messageListener" ref="primitive_input_q_listenerID_DateTime_1.2"/>
+ <property name="connectionFactory" ref="controllerJmsFactory"/>
+ <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_DateTime_1.2"
+ class="org.apache.uima.adapter.jms.activemq.JmsOutputChannel"
+ init-method="initialize">
+ <property name="serviceInputEndpoint" value="inQ_DateTime_1.2"/>
+ <property name="controller" ref="primitive_ctlr_DateTime_1.2"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- Internal Input Queue for -->
+ <!-- Meeting -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="inQ_Meeting_1.3" class="org.apache.activemq.command.ActiveMQQueue">
+ <constructor-arg index="0" value="inQ_Meeting_1.3"/>
+ </bean>
+ <!--======================================-->
+ <!-- Primitive or non-Async Aggr: Meeting -->
+ <!--======================================-->
+ <bean id="primitive_ctlr_Meeting_1.3"
+ class="org.apache.uima.aae.controller.PrimitiveAnalysisEngineController_impl"
+ init-method="initialize">
+ <constructor-arg index="0" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
+
+ <!-- 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"/>
+ <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"/>
+ <property name="outputChannel" ref="outChnl_Meeting_1.3"/>
+ </bean>
+
+ <!-- ThreadPool Task Executor -->
+ <bean id="pooling_Meeting_1.3"
+ class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
+ <property name="corePoolSize" value="1"/>
+ <property name="maxPoolSize" value="1"/>
+ <property name="queueCapacity" value="1"/>
+ </bean>
+
+ <!--=============================================-->
+ <!-- M E S S A G E H A N D L E R: primitive -->
+ <!-- for controller: primitive_ctlr_Meeting_1.3 -->
+ <!--=============================================-->
+
+ <bean id="primitive_metaMsgHandler_Meeting_1.3"
+ class="org.apache.uima.aae.handler.input.MetadataRequestHandler_impl">
+ <constructor-arg index="0" value="MetadataRequestHandler"/>
+ <property name="controller" ref="primitive_ctlr_Meeting_1.3"/>
+ <property name="delegate" ref="primitive_processRequestHandler_Meeting_1.3"/>
+ </bean>
+
+ <bean id="primitive_processRequestHandler_Meeting_1.3"
+ class="org.apache.uima.aae.handler.input.ProcessRequestHandler_impl">
+ <constructor-arg index="0" value="ProcessRequestHandler"/>
+ <property name="controller" ref="primitive_ctlr_Meeting_1.3"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener for input queue for: -->
+ <!-- inQ_Meeting_1.3 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_q_listenerID_Meeting_1.3"
+ class="org.apache.uima.adapter.jms.activemq.JmsInputChannel">
+ <property name="messageHandler" ref="primitive_metaMsgHandler_Meeting_1.3"/>
+ <property name="endpointName" value="inQ_Meeting_1.3"/>
+ <property name="controller" ref="primitive_ctlr_Meeting_1.3"/>
+ <property name="listenerContainer" ref="primitive_input_msgLsnrCntnr_Meeting_1.3"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- JMS msg listener container for input queue for: -->
+ <!-- inQ_Meeting_1.3 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_msgLsnrCntnr_Meeting_1.3"
+ class="org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer">
+
+ <!-- Connect to pooling task executor for primitive -->
+ <property name="taskExecutor" ref="pooling_Meeting_1.3"/>
+
+ <!-- Define number of JMS Consumers -->
+ <property name="concurrentConsumers" value="1"/>
+
+ <!-- input Queue -->
+ <property name="destination" ref="inQ_Meeting_1.3"/>
+
+ <!-- POJO to delegate JMS Messages to -->
+ <property name="messageListener" ref="primitive_input_q_listenerID_Meeting_1.3"/>
+ <property name="connectionFactory" ref="controllerJmsFactory"/>
+ <property name="messageSelector" value="Command=2000 OR Command=2002"/>
+ </bean>
+
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <!-- GetMeta JMS msg listener container for input queue for: -->
+ <!-- inQ_Meeting_1.3 -->
+ <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
+ <bean id="primitive_input_msgLsnrCntnr_Meeting_1.3_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="inQ_Meeting_1.3"/>
+
+ <!-- POJO to delegate JMS Messages to -->
+ <property name="messageListener" ref="primitive_input_q_listenerID_Meeting_1.3"/>
+ <property name="connectionFactory" ref="controllerJmsFactory"/>
+ <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_Meeting_1.3"
+ class="org.apache.uima.adapter.jms.activemq.JmsOutputChannel"
+ init-method="initialize">
+ <property name="serviceInputEndpoint" value="inQ_Meeting_1.3"/>
+ <property name="controller" ref="primitive_ctlr_Meeting_1.3"/>
+ </bean>
+</beans>
\ No newline at end of file