You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2013/04/04 16:33:09 UTC
svn commit: r1464568 -
/activemq/trunk/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java
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() {