[
https://issues.apache.org/jira/browse/UIMA-1140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12634628#action_12634628
]
Marshall Schor commented on UIMA-1140:
--------------------------------------
Jerry tested the above fix, and found a couple of issues:
dd2spring doesnt generate the ThreadPoolTaskExecutor bean in the Primitive Top
Level sping xml, which should look like:
<!-- ThreadPool Task Executor -->
<bean id="pooling_NoOpAnnotatorQueue2_1"
class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
<property name="corePoolSize" value="1"/>
<property name="maxPoolSize" value="1"/>
<property name="queueCapacity" value="1"/>
</bean>
This bean is required by the top level message listener.
<!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
<!-- JMS msg listener container for input queue for: -->
<!-- top_level_input_queue_service_1 -->
<!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -->
<bean id="primitive_input_msgLsnrCntnr_NoOpAnnotatorQueue_1"
class="org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer">
<!-- Connect to pooling task executor for primitive -->
<property name="taskExecutor" ref="pooling_NoOpAnnotatorQueue2_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_NoOpAnnotatorQueue_1"/>
<property name="connectionFactory"
ref="qBroker_tcp_c__ss_localhost_c_8118"/>
<property name="messageSelector" value="Command=2000 OR Command=2002"/>
</bean>
If there is a listener there should also be a corresponding
ThreadPoolTaskExecutor for it.
> Embedded broker should be eliminated
> ------------------------------------
>
> Key: UIMA-1140
> URL: https://issues.apache.org/jira/browse/UIMA-1140
> Project: UIMA
> Issue Type: Improvement
> Components: Async Scaleout
> Reporter: Eddie Epstein
> Assignee: Marshall Schor
> Attachments: uimaj-as-activemq-UIMA-1140-patch.txt,
> uimaj-as-core-UIMA-1140-patch.txt, uimaj-as-jms-UIMA-1140-patch.txt
>
>
> When an async aggregate is deployed, the request/reply queues for colocated
> delegates use an embedded broker. After UIMA-1130 is complete, all reply
> queues for remote delegates will be located on the same external broker
> hosting the delegate's request queue. At that point the function of the
> colocated broker can be replace with simple Java queues.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
