Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix for: https://issues.apache.org/jira/browse/AMQ-4435 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1464568 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2013-04-04 14:33:09 +00:00
parent 4aa87cedc5
commit 77fe814b9e
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
activemq-client/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java
View File

@ -180,6 +180,7 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
/** /**
* @return Returns the Connection. * @return Returns the Connection.
*/ */
@Override
public Connection createConnection() throws JMSException { public Connection createConnection() throws JMSException {
return createActiveMQConnection(); return createActiveMQConnection();
} }
@ -187,6 +188,7 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
/** /**
* @return Returns the Connection. * @return Returns the Connection.
*/ */
@Override
public Connection createConnection(String userName, String password) throws JMSException { public Connection createConnection(String userName, String password) throws JMSException {
return createActiveMQConnection(userName, password); return createActiveMQConnection(userName, password);
} }
@ -195,6 +197,7 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
* @return Returns the QueueConnection. * @return Returns the QueueConnection.
* @throws JMSException * @throws JMSException
*/ */
@Override
public QueueConnection createQueueConnection() throws JMSException { public QueueConnection createQueueConnection() throws JMSException {
return createActiveMQConnection().enforceQueueOnlyConnection(); return createActiveMQConnection().enforceQueueOnlyConnection();
} }
@ -202,6 +205,7 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
/** /**
* @return Returns the QueueConnection. * @return Returns the QueueConnection.
*/ */
@Override
public QueueConnection createQueueConnection(String userName, String password) throws JMSException { public QueueConnection createQueueConnection(String userName, String password) throws JMSException {
return createActiveMQConnection(userName, password).enforceQueueOnlyConnection(); return createActiveMQConnection(userName, password).enforceQueueOnlyConnection();
} }
@ -210,6 +214,7 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
* @return Returns the TopicConnection. * @return Returns the TopicConnection.
* @throws JMSException * @throws JMSException
*/ */
@Override
public TopicConnection createTopicConnection() throws JMSException { public TopicConnection createTopicConnection() throws JMSException {
return createActiveMQConnection(); return createActiveMQConnection();
} }
@ -217,6 +222,7 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
/** /**
* @return Returns the TopicConnection. * @return Returns the TopicConnection.
*/ */
@Override
public TopicConnection createTopicConnection(String userName, String password) throws JMSException { public TopicConnection createTopicConnection(String userName, String password) throws JMSException {
return createActiveMQConnection(userName, password); return createActiveMQConnection(userName, password);
} }
@ -224,6 +230,7 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
/** /**
* @returns the StatsImpl associated with this ConnectionFactory. * @returns the StatsImpl associated with this ConnectionFactory.
*/ */
@Override
public StatsImpl getStats() { public StatsImpl getStats() {
return this.factoryStats; return this.factoryStats;
} }
@ -756,6 +763,7 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
props.setProperty("nonBlockingRedelivery", Boolean.toString(isNonBlockingRedelivery())); props.setProperty("nonBlockingRedelivery", Boolean.toString(isNonBlockingRedelivery()));
props.setProperty("maxThreadPoolSize", Integer.toString(getMaxThreadPoolSize())); props.setProperty("maxThreadPoolSize", Integer.toString(getMaxThreadPoolSize()));
props.setProperty("nestedMapAndListEnabled", Boolean.toString(isNestedMapAndListEnabled())); props.setProperty("nestedMapAndListEnabled", Boolean.toString(isNestedMapAndListEnabled()));
props.setProperty("consumerFailoverRedeliveryWaitPeriod", Long.toString(getConsumerFailoverRedeliveryWaitPeriod()));
} }
public boolean isUseCompression() { public boolean isUseCompression() {