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

ARTEMIS-1255 Fixed authentication issues with XAConnectionFactory 

Added the global user/password variables to all of the variations of the createContext/createConnectionFactory methods.

(cherry picked from commit 177bda4892)
This commit is contained in:
Josh Reagan 2017-06-26 16:41:22 -06:00 committed by Clebert Suconic
parent 144a7c8a42
commit 21f86a4844
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQConnectionFactory.java
View File

@ -309,7 +309,7 @@ public class ActiveMQConnectionFactory implements ConnectionFactoryOptions, Exte
} }
public QueueConnection createQueueConnection() throws JMSException { public QueueConnection createQueueConnection() throws JMSException {
return createQueueConnection(null, null); return createQueueConnection(user, password);
} }
public QueueConnection createQueueConnection(final String username, final String password) throws JMSException { public QueueConnection createQueueConnection(final String username, final String password) throws JMSException {
@ -319,7 +319,7 @@ public class ActiveMQConnectionFactory implements ConnectionFactoryOptions, Exte
// TopicConnectionFactory implementation -------------------------------------------------------- // TopicConnectionFactory implementation --------------------------------------------------------
public TopicConnection createTopicConnection() throws JMSException { public TopicConnection createTopicConnection() throws JMSException {
return createTopicConnection(null, null); return createTopicConnection(user, password);
} }
public TopicConnection createTopicConnection(final String username, final String password) throws JMSException { public TopicConnection createTopicConnection(final String username, final String password) throws JMSException {
@ -330,7 +330,7 @@ public class ActiveMQConnectionFactory implements ConnectionFactoryOptions, Exte
@Override @Override
public XAConnection createXAConnection() throws JMSException { public XAConnection createXAConnection() throws JMSException {
return createXAConnection(null, null); return createXAConnection(user, password);
} }
@Override @Override
@ -340,7 +340,7 @@ public class ActiveMQConnectionFactory implements ConnectionFactoryOptions, Exte
@Override @Override
public XAJMSContext createXAContext() { public XAJMSContext createXAContext() {
return createXAContext(null, null); return createXAContext(user, password);
} }
@Override @Override
@ -358,7 +358,7 @@ public class ActiveMQConnectionFactory implements ConnectionFactoryOptions, Exte
// XAQueueConnectionFactory implementation ------------------------------------------------------ // XAQueueConnectionFactory implementation ------------------------------------------------------
public XAQueueConnection createXAQueueConnection() throws JMSException { public XAQueueConnection createXAQueueConnection() throws JMSException {
return createXAQueueConnection(null, null); return createXAQueueConnection(user, password);
} }
public XAQueueConnection createXAQueueConnection(final String username, final String password) throws JMSException { public XAQueueConnection createXAQueueConnection(final String username, final String password) throws JMSException {
@ -368,7 +368,7 @@ public class ActiveMQConnectionFactory implements ConnectionFactoryOptions, Exte
// XATopicConnectionFactory implementation ------------------------------------------------------ // XATopicConnectionFactory implementation ------------------------------------------------------
public XATopicConnection createXATopicConnection() throws JMSException { public XATopicConnection createXATopicConnection() throws JMSException {
return createXATopicConnection(null, null); return createXATopicConnection(user, password);
} }
public XATopicConnection createXATopicConnection(final String username, final String password) throws JMSException { public XATopicConnection createXATopicConnection(final String username, final String password) throws JMSException {