svn commit: r1503453 - /uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsEndpointConnection_impl.java

[cwiklik]

Author: cwiklik
Date: Mon Jul 15 20:24:21 2013
New Revision: 1503453

URL: http://svn.apache.org/r1503453
Log:
UIMA-3079 added maxInactivityDuration=0 to broker URL on connection handling 
replies

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

Modified: 
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsEndpointConnection_impl.java
URL: 
http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsEndpointConnection_impl.java?rev=1503453&r1=1503452&r2=1503453&view=diff
==============================================================================
--- 
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsEndpointConnection_impl.java
 (original)
+++ 
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsEndpointConnection_impl.java
 Mon Jul 15 20:24:21 2013
@@ -193,6 +193,8 @@ public class JmsEndpointConnection_impl 
                                    new Object[] {  aComponentName, 
getEndpoint(),
                                      ((JmsOutputChannel) 
aController.getOutputChannel()).getServerURI() });
                          }
+                       } else if ( !brokerUri.startsWith("http") && 
!brokerUri.startsWith("failover")){
+                             brokerUri += 
"?wireFormat.maxInactivityDuration=0";
                        }
 
                        if (!isOpen()) {
@@ -217,10 +219,11 @@ public class JmsEndpointConnection_impl 
                                  //  Ignore exceptions on a close of a bad 
connection
                                }
                              }
-                             System.out.println("---------- Opening New Broker 
Connection ---------------");
+                             System.out.println("---------- Opening New Broker 
Connection ---------------"+brokerUri);
                              ActiveMQConnectionFactory factory = new 
ActiveMQConnectionFactory(brokerUri);
                              //  Create shared jms connection to a broker
                              conn = factory.createConnection();
+                             
                              factory.setDispatchAsync(true);
                              factory.setUseAsyncSend(true);
                              factory.setCopyMessageOnSend(false);