Author: cwiklik
Date: Wed Feb 9 18:35:21 2011
New Revision: 1069025
URL: http://svn.apache.org/viewvc?rev=1069025&view=rev
Log:
UIMA-2038 Modified produceListenerConnector()
Modified:
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/SpringContainerDeployer.java
Modified:
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/SpringContainerDeployer.java
URL:
http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/SpringContainerDeployer.java?rev=1069025&r1=1069024&r2=1069025&view=diff
==============================================================================
---
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/SpringContainerDeployer.java
(original)
+++
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/SpringContainerDeployer.java
Wed Feb 9 18:35:21 2011
@@ -77,15 +77,17 @@ public class SpringContainerDeployer imp
springContainerRegistry = aSpringContainerRegistry;
}
- private UimaDefaultMessageListenerContainer
produceListenerConnector(ActiveMQConnectionFactory cf) {
+ private UimaDefaultMessageListenerContainer
produceListenerConnector(ActiveMQConnectionFactory cf, AnalysisEngineController
ctrl) {
DestinationResolver resolver = new TempDestinationResolver();
UimaDefaultMessageListenerContainer connector = new
UimaDefaultMessageListenerContainer(true);
connector.setConnectionFactory(cf);
connector.setConcurrentConsumers(1);
connector.setDestinationResolver(resolver);
-
+ connector.setController(ctrl);
+ connector.setMessageListener(((JmsInputChannel) ctrl.getInputChannel()));
connector.initializeContainer();
-
+ connector.getDestination();
+ connector.afterPropertiesSet(false);
connector.start();
synchronized (mux) {
while (connector.getListenerEndpoint() == null) {
@@ -184,9 +186,9 @@ public class SpringContainerDeployer imp
ActiveMQPrefetchPolicy prefetchPolicy =
getPrefetchPolicy(MAX_PREFETCH_FOR_CAS_NOTIFICATION_Q);
cf.setPrefetchPolicy(prefetchPolicy);
// Create a listener and a temp queue for Free CAS notifications.
- UimaDefaultMessageListenerContainer connector =
produceListenerConnector(cf);
+ UimaDefaultMessageListenerContainer connector =
produceListenerConnector(cf,cntlr);
// Direct all messages to the InputChannel
- connector.setMessageListener(((JmsInputChannel)
cntlr.getInputChannel()));
+ //connector.setMessageListener(((JmsInputChannel)
cntlr.getInputChannel()));
((JmsInputChannel)
cntlr.getInputChannel()).setListenerContainer(connector);
// Save the temp queue reference in the Output Channel. The output
channel will
// add this queue to every outgoing message containing a CAS generated
by the
