[
https://issues.apache.org/jira/browse/UIMA-1140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12636653#action_12636653
]
Jerry Cwiklik commented on UIMA-1140:
-------------------------------------
Need dd2spring change to add a new property to each collocated endpoint bean
which specifies a number of concurrent listener threads that will process
requests. With AMQ the concurrentConsumers property was set on the
MessageListener bean which is no longer present for collocated delegate.
Collocated uima as services use a java queue and ThreadPoolExecutor. The latter
may be configured to process messages concurrently in multiple threads. An
example Endpoint bean with the new property would like this:
<!-- ==================================== -->
<!-- InnerTestMultiplier -->
<!-- ** Delegate Endpoint ** -->
<!-- ==================================== -->
<bean id="endpt_InnerTestMultiplier_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_InnerTestMultiplier_1.1"/>
<!-- Timeouts -->
<property name="metadataRequestTimeout" value="0"/>
<property name="processRequestTimeout" value="0"/>
<property name="collectionProcessCompleteTimeout" value="0"/>
<property name="concurrentConsumers" value="3"/>
</bean>
The value for the above bean's concurrentConsumers should be the same value the
was previously set on the Message Listener bean of the collocated service.
> 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.
