activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1464568 - /activemq/trunk/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java
Date Thu, 04 Apr 2013 14:33:09 GMT
Author: tabish
Date: Thu Apr  4 14:33:09 2013
New Revision: 1464568

URL: http://svn.apache.org/r1464568
Log:
fix for: https://issues.apache.org/jira/browse/AMQ-4435

Modified:
    activemq/trunk/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java

Modified: activemq/trunk/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java?rev=1464568&r1=1464567&r2=1464568&view=diff
==============================================================================
--- activemq/trunk/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java
(original)
+++ activemq/trunk/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java
Thu Apr  4 14:33:09 2013
@@ -180,6 +180,7 @@ public class ActiveMQConnectionFactory e
     /**
      * @return Returns the Connection.
      */
+    @Override
     public Connection createConnection() throws JMSException {
         return createActiveMQConnection();
     }
@@ -187,6 +188,7 @@ public class ActiveMQConnectionFactory e
     /**
      * @return Returns the Connection.
      */
+    @Override
     public Connection createConnection(String userName, String password) throws JMSException
{
         return createActiveMQConnection(userName, password);
     }
@@ -195,6 +197,7 @@ public class ActiveMQConnectionFactory e
      * @return Returns the QueueConnection.
      * @throws JMSException
      */
+    @Override
     public QueueConnection createQueueConnection() throws JMSException {
         return createActiveMQConnection().enforceQueueOnlyConnection();
     }
@@ -202,6 +205,7 @@ public class ActiveMQConnectionFactory e
     /**
      * @return Returns the QueueConnection.
      */
+    @Override
     public QueueConnection createQueueConnection(String userName, String password) throws
JMSException {
         return createActiveMQConnection(userName, password).enforceQueueOnlyConnection();
     }
@@ -210,6 +214,7 @@ public class ActiveMQConnectionFactory e
      * @return Returns the TopicConnection.
      * @throws JMSException
      */
+    @Override
     public TopicConnection createTopicConnection() throws JMSException {
         return createActiveMQConnection();
     }
@@ -217,6 +222,7 @@ public class ActiveMQConnectionFactory e
     /**
      * @return Returns the TopicConnection.
      */
+    @Override
     public TopicConnection createTopicConnection(String userName, String password) throws
JMSException {
         return createActiveMQConnection(userName, password);
     }
@@ -224,6 +230,7 @@ public class ActiveMQConnectionFactory e
     /**
      * @returns the StatsImpl associated with this ConnectionFactory.
      */
+    @Override
     public StatsImpl getStats() {
         return this.factoryStats;
     }
@@ -756,6 +763,7 @@ public class ActiveMQConnectionFactory e
         props.setProperty("nonBlockingRedelivery", Boolean.toString(isNonBlockingRedelivery()));
         props.setProperty("maxThreadPoolSize", Integer.toString(getMaxThreadPoolSize()));
         props.setProperty("nestedMapAndListEnabled", Boolean.toString(isNestedMapAndListEnabled()));
+        props.setProperty("consumerFailoverRedeliveryWaitPeriod", Long.toString(getConsumerFailoverRedeliveryWaitPeriod()));
     }
 
     public boolean isUseCompression() {



Mime
View raw message