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.
This commit is contained in:
Josh Reagan 2017-06-26 16:41:22 -06:00 committed by Clebert Suconic
parent c48d968931
commit 177bda4892
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

@ -311,7 +311,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 {
@ -321,7 +321,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 {
@ -332,7 +332,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
@ -342,7 +342,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
@ -360,7 +360,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 {
@ -370,7 +370,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 {