ARTEMIS-1255 Fixed authentication issues with XAConnectionFactory Added the global user/password variables to all of the variations of the createContext/createConnectionFactory methods.
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/177bda48 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/177bda48 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/177bda48 Branch: refs/heads/master Commit: 177bda4892b0aabd89311ec28b91762fb22ebaae Parents: c48d968 Author: Josh Reagan <[email protected]> Authored: Mon Jun 26 16:41:22 2017 -0600 Committer: Clebert Suconic <[email protected]> Committed: Tue Jun 27 14:25:47 2017 -0400 ---------------------------------------------------------------------- .../artemis/jms/client/ActiveMQConnectionFactory.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/177bda48/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQConnectionFactory.java ---------------------------------------------------------------------- diff --git a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQConnectionFactory.java b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQConnectionFactory.java index 06acd25..bd5fccf 100644 --- a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQConnectionFactory.java +++ b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQConnectionFactory.java @@ -311,7 +311,7 @@ public class ActiveMQConnectionFactory implements ConnectionFactoryOptions, Exte } public QueueConnection createQueueConnection() throws JMSException { - return createQueueConnection(null, null); + return createQueueConnection(user, password); } public QueueConnection createQueueConnection(final String username, final String password) throws JMSException { @@ -321,7 +321,7 @@ public class ActiveMQConnectionFactory implements ConnectionFactoryOptions, Exte // TopicConnectionFactory implementation -------------------------------------------------------- public TopicConnection createTopicConnection() throws JMSException { - return createTopicConnection(null, null); + return createTopicConnection(user, password); } public TopicConnection createTopicConnection(final String username, final String password) throws JMSException { @@ -332,7 +332,7 @@ public class ActiveMQConnectionFactory implements ConnectionFactoryOptions, Exte @Override public XAConnection createXAConnection() throws JMSException { - return createXAConnection(null, null); + return createXAConnection(user, password); } @Override @@ -342,7 +342,7 @@ public class ActiveMQConnectionFactory implements ConnectionFactoryOptions, Exte @Override public XAJMSContext createXAContext() { - return createXAContext(null, null); + return createXAContext(user, password); } @Override @@ -360,7 +360,7 @@ public class ActiveMQConnectionFactory implements ConnectionFactoryOptions, Exte // XAQueueConnectionFactory implementation ------------------------------------------------------ public XAQueueConnection createXAQueueConnection() throws JMSException { - return createXAQueueConnection(null, null); + return createXAQueueConnection(user, password); } public XAQueueConnection createXAQueueConnection(final String username, final String password) throws JMSException { @@ -370,7 +370,7 @@ public class ActiveMQConnectionFactory implements ConnectionFactoryOptions, Exte // XATopicConnectionFactory implementation ------------------------------------------------------ public XATopicConnection createXATopicConnection() throws JMSException { - return createXATopicConnection(null, null); + return createXATopicConnection(user, password); } public XATopicConnection createXATopicConnection(final String username, final String password) throws JMSException {
