uima-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sc...@apache.org
Subject svn commit: r702261 [3/4] - 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/descriptors/analysis_engine/ test/resources/des...
Date Mon, 06 Oct 2008 21:01:49 GMT
Modified: 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=702261&r1=702260&r2=702261&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq2AEg.xml (original)
+++ incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq2AEg.xml Mon Oct  6 14:01:48 2008
@@ -2,25 +2,12 @@
 <!--==============================================================================-->
  <!-- Generated from                                                               -->
  <!-- file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/deploy/iq2AEg.xml -->
- <!-- 25 August, 2008, 4:01:49 P.M.                                                -->
+ <!-- 6 October, 2008, 3:56:56 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"
@@ -134,41 +121,6 @@
       <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 -->
    
@@ -189,6 +141,8 @@
      <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>
 
    <!-- ==================================== -->
@@ -207,6 +161,8 @@
      <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>
 
    <!-- ==================================== -->
@@ -225,6 +181,8 @@
      <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>
 
    <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
@@ -281,43 +239,6 @@
       <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  -->
@@ -424,14 +345,6 @@
          </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 -->
    <!--=========================================-->
@@ -452,106 +365,6 @@
 
      <!-- 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 -->
@@ -573,106 +386,6 @@
 
      <!-- 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 -->
@@ -694,97 +407,5 @@
 
      <!-- 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

Modified: 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=702261&r1=702260&r2=702261&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq2AEg2.xml (original)
+++ incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq2AEg2.xml Mon Oct  6 14:01:48 2008
@@ -2,25 +2,12 @@
 <!--===============================================================================-->
  <!-- Generated from                                                                -->
  <!-- file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/deploy/iq2AEg2.xml -->
- <!-- 25 August, 2008, 4:08:44 P.M.                                                 -->
+ <!-- 6 October, 2008, 3:25:18 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"
@@ -134,41 +121,6 @@
       <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 -->
    
@@ -189,6 +141,8 @@
      <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>
 
    <!-- ==================================== -->
@@ -207,6 +161,8 @@
      <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>
 
    <!-- ==================================== -->
@@ -225,6 +181,8 @@
      <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>
 
    <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
@@ -281,43 +239,6 @@
       <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  -->
@@ -424,14 +345,6 @@
          </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 -->
    <!--=========================================-->
@@ -452,106 +365,6 @@
 
      <!-- 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 -->
@@ -573,106 +386,6 @@
 
      <!-- 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 -->
@@ -694,97 +407,5 @@
 
      <!-- 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

Modified: incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq3.xml
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq3.xml?rev=702261&r1=702260&r2=702261&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq3.xml (original)
+++ incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/iq3.xml Mon Oct  6 14:01:48 2008
@@ -2,25 +2,12 @@
 <!--===========================================================================-->
  <!-- Generated from                                                            -->
  <!-- file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/deploy/iq3.xml -->
- <!-- 25 August, 2008, 3:10:15 P.M.                                             -->
+ <!-- 6 October, 2008, 3:23:08 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"
@@ -159,23 +146,9 @@
    <!--  for controller: asAggr_ctlr_MeetingDetectorTaeQueue_1 -->
    <!--========================================================-->
    
-   <bean id="aggregate_return_metaMsgHandler_MeetingDetectorTaeQueue_1"
-         class="org.apache.uima.aae.handler.input.MetadataRequestHandler_impl">
-      <constructor-arg index="0" value="MetadataRequestHandler"/>
-      <property name="controller" ref="asAggr_ctlr_MeetingDetectorTaeQueue_1"/>
-      <property name="delegate"
-                ref="aggregate_return_processRequestHandler_MeetingDetectorTaeQueue_1"/>
-   </bean>
+    
 
-   <bean id="aggregate_return_processRequestHandler_MeetingDetectorTaeQueue_1"
-         class="org.apache.uima.aae.handler.input.ProcessRequestHandler_impl">
-      <constructor-arg index="0" value="ProcessRequestHandler"/>
-      <property name="controller" ref="asAggr_ctlr_MeetingDetectorTaeQueue_1"/>
-      <property name="delegate"
-                ref="aggregate_return_processResponseHandler_MeetingDetectorTaeQueue_1"/>
-   </bean>
-
-   <bean id="aggregate_return_processResponseHandler_MeetingDetectorTaeQueue_1"
+<bean id="aggregate_return_processResponseHandler_MeetingDetectorTaeQueue_1"
          class="org.apache.uima.aae.handler.input.ProcessResponseHandler">
       <constructor-arg index="0" value="ProcessResponseHandler"/>
       <property name="controller" ref="asAggr_ctlr_MeetingDetectorTaeQueue_1"/>
@@ -187,6 +160,14 @@
          class="org.apache.uima.aae.handler.input.MetadataResponseHandler_impl">
       <constructor-arg index="0" value="MetadataResponseHandler"/>
       <property name="controller" ref="asAggr_ctlr_MeetingDetectorTaeQueue_1"/>
+      <property name="delegate"
+                ref="aggregate_return_processRequestHandler_MeetingDetectorTaeQueue_1"/>
+   </bean>
+
+   <bean id="aggregate_return_processRequestHandler_MeetingDetectorTaeQueue_1"
+         class="org.apache.uima.aae.handler.input.ProcessRequestHandler_impl">
+      <constructor-arg index="0" value="ProcessRequestHandler"/>
+      <property name="controller" ref="asAggr_ctlr_MeetingDetectorTaeQueue_1"/>
    </bean>
 
    <!-- Create the endpoints + output channels, one per delegate -->
@@ -206,7 +187,7 @@
 
      <!-- Queue name used for replies, on the remote broker  -->
      <property name="replyToEndpoint"
-                value="rmtRtrnQ_MeetingDetectorTaeQueue_1_Segmenter_9.2.34.653840ec21:11bfb4609b0:-8000"/>
+                value="rmtRtrnQ_MeetingDetectorTaeQueue_1_Segmenter_9.2.34.805b199f85:11cd396016e:-7ffd"/>
       <property name="shadowCasPoolSize" value="7"/>
       <property name="initialFsHeapSize" value="999"/>
 
@@ -234,6 +215,8 @@
      <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>
 
    <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
@@ -290,49 +273,12 @@
       <property name="messageSelector" value="Command=2001"/>
    </bean>
 
-   <!-- return queue for async aggregate -->
-   <bean id="asynAggr_retQ_MeetingDetectorTaeQueue_1"
-         class="org.apache.activemq.command.ActiveMQQueue">
-      <constructor-arg index="0" value="asynAggr_retQ_MeetingDetectorTaeQueue_1"/>
-   </bean>
-
-   <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
-   <!--  JMS msg listener for return queue for:  -->
-   <!-- asynAggr_retQ_MeetingDetectorTaeQueue_1  -->
-   <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
-   <bean id="asAggr_return_q_listenerID_MeetingDetectorTaeQueue_1"
-         class="org.apache.uima.adapter.jms.activemq.JmsInputChannel">
-      <property name="messageHandler"
-                ref="aggregate_return_metaMsgHandler_MeetingDetectorTaeQueue_1"/>
-      <property name="endpointName" value="asynAggr_retQ_MeetingDetectorTaeQueue_1"/>
-      <property name="controller" ref="asAggr_ctlr_MeetingDetectorTaeQueue_1"/>
-   </bean>
-
-   <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~-->
-   <!-- JMS msg listener container for return queue for: -->
-   <!--     asynAggr_retQ_MeetingDetectorTaeQueue_1      -->
-   <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~-->
-   <bean id="asAggr_return_msgLsnrCntnr_MeetingDetectorTaeQueue_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_MeetingDetectorTaeQueue_1"/>
-
-     <!-- POJO to delegate JMS Messages to -->
-     <property name="messageListener"
-                ref="asAggr_return_q_listenerID_MeetingDetectorTaeQueue_1"/>
-      <property name="connectionFactory" ref="controllerJmsFactory"/>
-   </bean>
-
    <!-- return queue for http or tcp remote service  -->
    <!--               on remote broker               -->
    <bean id="rmtRtrnQ_MeetingDetectorTaeQueue_1_Segmenter"
          class="org.apache.activemq.command.ActiveMQQueue">
       <constructor-arg index="0"
-                       value="rmtRtrnQ_MeetingDetectorTaeQueue_1_Segmenter_9.2.34.653840ec21:11bfb4609b0:-8000"/>
+                       value="rmtRtrnQ_MeetingDetectorTaeQueue_1_Segmenter_9.2.34.805b199f85:11cd396016e:-7ffd"/>
    </bean>
 
    <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~-->
@@ -342,7 +288,7 @@
    <bean id="asAggr_return_q_listenerID_MeetingDetectorTaeQueue_1_Segmenter"
          class="org.apache.uima.adapter.jms.activemq.JmsInputChannel">
       <property name="messageHandler"
-                ref="aggregate_return_metaMsgHandler_MeetingDetectorTaeQueue_1"/>
+                ref="aggregate_return_processResponseHandler_MeetingDetectorTaeQueue_1"/>
       <property name="endpointName" value=""/>
       <property name="controller" ref="asAggr_ctlr_MeetingDetectorTaeQueue_1"/>
    </bean>
@@ -473,14 +419,6 @@
          </list>
       </constructor-arg>
    </bean>
-
-   <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
-   <!--   Internal Input Queue for   -->
-   <!--          Tokenizer           -->
-   <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
-   <bean id="inQ_Tokenizer_1.2" class="org.apache.activemq.command.ActiveMQQueue">
-      <constructor-arg index="0" value="inQ_Tokenizer_1.2"/>
-   </bean>
    <!--========================================-->
    <!-- Primitive or non-Async Aggr: Tokenizer -->
    <!--========================================-->
@@ -501,97 +439,5 @@
 
      <!-- scaleout number of instances -->
      <constructor-arg index="6" value="1"/>
-      <property name="outputChannel" ref="outChnl_Tokenizer_1.2"/>
-   </bean>
-
-   <!-- ThreadPool Task Executor -->
-   <bean id="pooling_Tokenizer_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_Tokenizer_1.2 -->
-   <!--===============================================-->
-   
-   <bean id="primitive_metaMsgHandler_Tokenizer_1.2"
-         class="org.apache.uima.aae.handler.input.MetadataRequestHandler_impl">
-      <constructor-arg index="0" value="MetadataRequestHandler"/>
-      <property name="controller" ref="primitive_ctlr_Tokenizer_1.2"/>
-      <property name="delegate" ref="primitive_processRequestHandler_Tokenizer_1.2"/>
-   </bean>
-
-   <bean id="primitive_processRequestHandler_Tokenizer_1.2"
-         class="org.apache.uima.aae.handler.input.ProcessRequestHandler_impl">
-      <constructor-arg index="0" value="ProcessRequestHandler"/>
-      <property name="controller" ref="primitive_ctlr_Tokenizer_1.2"/>
-   </bean>
-
-   <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
-   <!-- JMS msg listener for input queue for:  -->
-   <!--           inQ_Tokenizer_1.2            -->
-   <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
-   <bean id="primitive_input_q_listenerID_Tokenizer_1.2"
-         class="org.apache.uima.adapter.jms.activemq.JmsInputChannel">
-      <property name="messageHandler" ref="primitive_metaMsgHandler_Tokenizer_1.2"/>
-      <property name="endpointName" value="inQ_Tokenizer_1.2"/>
-      <property name="controller" ref="primitive_ctlr_Tokenizer_1.2"/>
-      <property name="listenerContainer" ref="primitive_input_msgLsnrCntnr_Tokenizer_1.2"/>
-   </bean>
-
-   <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
-   <!-- JMS msg listener container for input queue for:  -->
-   <!--                inQ_Tokenizer_1.2                 -->
-   <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
-   <bean id="primitive_input_msgLsnrCntnr_Tokenizer_1.2"
-         class="org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer">
-
-     <!-- Connect to pooling task executor for primitive -->
-     <property name="taskExecutor" ref="pooling_Tokenizer_1.2"/>
-
-     <!-- Define number of JMS Consumers -->
-     <property name="concurrentConsumers" value="1"/>
-
-     <!--    input Queue     -->
-     <property name="destination" ref="inQ_Tokenizer_1.2"/>
-
-     <!-- POJO to delegate JMS Messages to -->
-     <property name="messageListener" ref="primitive_input_q_listenerID_Tokenizer_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_Tokenizer_1.2                     -->
-   <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
-   <bean id="primitive_input_msgLsnrCntnr_Tokenizer_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_Tokenizer_1.2"/>
-
-     <!-- POJO to delegate JMS Messages to -->
-     <property name="messageListener" ref="primitive_input_q_listenerID_Tokenizer_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_Tokenizer_1.2"
-         class="org.apache.uima.adapter.jms.activemq.JmsOutputChannel"
-         init-method="initialize">
-      <property name="serviceInputEndpoint" value="inQ_Tokenizer_1.2"/>
-      <property name="controller" ref="primitive_ctlr_Tokenizer_1.2"/>
    </bean>
 </beans>
\ No newline at end of file

Modified: incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/tempQ1.xml
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/tempQ1.xml?rev=702261&r1=702260&r2=702261&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/tempQ1.xml (original)
+++ incubator/uima/sandbox/trunk/uima-as/uima-as-distr/src/test/resources/deploy/expected/tempQ1.xml Mon Oct  6 14:01:48 2008
@@ -1,26 +1,13 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<!--=================================================================================-->
- <!-- Generated from                                                                  -->
- <!-- file:/C:/a/Eclipse/3.3/apache/uima-as-distr/src/test/resources/deploy/tempQ1.xml -->
- <!-- 10 December, 2007, 1:52:26 P.M.                                                 -->
- <!--=================================================================================-->
+<!--==============================================================================-->
+ <!-- Generated from                                                               -->
+ <!-- file:/C:/a/Eclipse/apache/uima-as-distr/src/test/resources/deploy/tempQ1.xml -->
+ <!-- 6 October, 2008, 4:24:18 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"
@@ -104,7 +91,7 @@
       </constructor-arg>
       <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:/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"/>
@@ -140,23 +127,9 @@
    <!--  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"
+<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"/>
@@ -168,6 +141,14 @@
          class="org.apache.uima.aae.handler.input.MetadataResponseHandler_impl">
       <constructor-arg index="0" value="MetadataResponseHandler"/>
       <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"/>
    </bean>
 
    <!-- Create the endpoints + output channels, one per delegate -->
@@ -185,16 +166,16 @@
      <!-- Delegate key name or remote queue name -->
      <property name="endpoint" value="RoomNumber"/>
 
-     <!-- Queue name used for replies, on the remote broker  -->
-     <property name="replyToEndpoint"
-                value="rmtRtrnQ_RoomNumberAnnotatorQueue_1_RoomNumber_9.2.34.65754d945a:11bfaf7fad7:-7fff"/>
-
+     <!-- Queue name used for replies, on the remote broker  -->
+     <property name="replyToEndpoint"
+                value="rmtRtrnQ_RoomNumberAnnotatorQueue_1_RoomNumber_9.2.34.805b199f85:11cd396016e:-7ffc"/>
+
      <!--      Timeouts      -->
      <property name="metadataRequestTimeout" value="60000"/>
       <property name="processRequestTimeout" value="0"/>
       <property name="collectionProcessCompleteTimeout" value="0"/>
       <property name="serializer" value=""/>
-      <property name="tempReplyDestination" value="true"/>
+      <property name="tempReplyDestination" value="true"/>
    </bean>
 
    <!-- ==================================== -->
@@ -213,6 +194,8 @@
      <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>
 
    <!-- ==================================== -->
@@ -231,6 +214,8 @@
      <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>
 
    <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
@@ -287,51 +272,14 @@
       <property name="messageSelector" value="Command=2001"/>
    </bean>
 
-   <!-- return queue for async aggregate -->
-   <bean id="asynAggr_retQ_RoomNumberAnnotatorQueue_1"
+   <!-- return queue for http or tcp remote service  -->
+   <!--               on remote broker               -->
+   <bean id="rmtRtrnQ_RoomNumberAnnotatorQueue_1_RoomNumber"
          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"/>
+      <constructor-arg index="0"
+                       value="rmtRtrnQ_RoomNumberAnnotatorQueue_1_RoomNumber_9.2.34.805b199f85:11cd396016e:-7ffc"/>
    </bean>
 
-   <!-- return queue for http or tcp remote service  -->
-   <!--               on remote broker               -->
-   <bean id="rmtRtrnQ_RoomNumberAnnotatorQueue_1_RoomNumber"
-         class="org.apache.activemq.command.ActiveMQQueue">
-      <constructor-arg index="0"
-                       value="rmtRtrnQ_RoomNumberAnnotatorQueue_1_RoomNumber_9.2.34.65754d945a:11bfaf7fad7:-7fff"/>
-   </bean>
-
    <!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~-->
    <!--     JMS msg listener for return queue for:     -->
    <!-- rmtRtrnQ_RoomNumberAnnotatorQueue_1_RoomNumber -->
@@ -339,7 +287,7 @@
    <bean id="asAggr_return_q_listenerID_RoomNumberAnnotatorQueue_1_RoomNumber"
          class="org.apache.uima.adapter.jms.activemq.JmsInputChannel">
       <property name="messageHandler"
-                ref="aggregate_return_metaMsgHandler_RoomNumberAnnotatorQueue_1"/>
+                ref="aggregate_return_processResponseHandler_RoomNumberAnnotatorQueue_1"/>
       <property name="endpointName" value=""/>
       <property name="controller" ref="asAggr_ctlr_RoomNumberAnnotatorQueue_1"/>
    </bean>
@@ -482,14 +430,6 @@
          </list>
       </constructor-arg>
    </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 -->
    <!--=======================================-->
@@ -501,7 +441,7 @@
      <!--      Key name      -->
      <constructor-arg index="1" value="DateTime"/>
       <constructor-arg index="2"
-                       value="file:/C:/a/Eclipse/3.3/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex4/../ex3/TutorialDateTime.xml"/>
+                       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"/>
 
@@ -510,106 +450,6 @@
 
      <!-- 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 -->
@@ -622,7 +462,7 @@
      <!--      Key name      -->
      <constructor-arg index="1" value="Meeting"/>
       <constructor-arg index="2"
-                       value="file:/C:/a/Eclipse/3.3/apache/uima-as-distr/src/test/resources/descriptors/tutorial/ex4/MeetingAnnotator.xml"/>
+                       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"/>
 
@@ -631,97 +471,5 @@
 
      <!-- 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



Mime
View raw message