svn commit: r815390 - /incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsInputChannel.java

[cw...@apache.org]

Author: cwiklik
Date: Tue Sep 15 16:45:22 2009
New Revision: 815390

URL: http://svn.apache.org/viewvc?rev=815390&view=rev
Log:
UIMA-1322 Fetch a broker URL from a message listener that handles GetMeta requests. Assign this broker URl to the Output Channel object to enable sending replies to temp queues managed by the same broker as the service's input queue.

Modified:
    incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsInputChannel.java

Modified: incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsInputChannel.java
URL: http://svn.apache.org/viewvc/incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsInputChannel.java?rev=815390&r1=815389&r2=815390&view=diff
==============================================================================
--- incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsInputChannel.java (original)
+++ incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsInputChannel.java Tue Sep 15 16:45:22 2009
@@ -682,7 +682,10 @@
   public synchronized void setListenerContainer(UimaDefaultMessageListenerContainer messageListener) {
     this.messageListener = messageListener;
     System.setProperty("BrokerURI", messageListener.getBrokerUrl());
-    brokerURL = messageListener.getBrokerUrl();
+    if ( messageListener.getMessageSelector() !=null && messageListener.getMessageSelector().equals("Command=2001") ) {
+      brokerURL = messageListener.getBrokerUrl();
+      getController().getOutputChannel().setServerURI(brokerURL);
+    }
     if (!listenerContainerList.contains(messageListener)) {
       listenerContainerList.add(messageListener);
     }