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

ARTEMIS-1053 use creds for active server check

This commit is contained in:
Justin Bertram 2017-03-21 10:20:18 -05:00 committed by Andy Taylor
parent 1282daf683
commit a9360f5599
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/SharedNothingLiveActivation.java
View File

@ -317,7 +317,7 @@ public class SharedNothingLiveActivation extends LiveActivation {
ClusterConnectionConfiguration config = ConfigurationUtils.getReplicationClusterConfiguration(activeMQServer.getConfiguration(), replicatedPolicy.getClusterName());
NodeIdListener listener = new NodeIdListener(nodeId0);
NodeIdListener listener = new NodeIdListener(nodeId0, activeMQServer.getConfiguration().getClusterUser(), activeMQServer.getConfiguration().getClusterPassword());
try (ServerLocatorInternal locator = getLocator(config)) {
locator.addClusterTopologyListener(listener);
@ -396,10 +396,14 @@ public class SharedNothingLiveActivation extends LiveActivation {
volatile boolean isNodePresent = false;
private final SimpleString nodeId;
private final String user;
private final String password;
private final CountDownLatch latch = new CountDownLatch(1);
NodeIdListener(SimpleString nodeId) {
NodeIdListener(SimpleString nodeId, String user, String password) {
this.nodeId = nodeId;
this.user = user;
this.password = password;
}
@Override
@ -428,10 +432,12 @@ public class SharedNothingLiveActivation extends LiveActivation {
try (ServerLocator serverLocator = ActiveMQClient.createServerLocator(false, transportConfiguration);
ClientSessionFactory clientSessionFactory = serverLocator.createSessionFactory();
ClientSession clientSession = clientSessionFactory.createSession();) {
ClientSession clientSession = clientSessionFactory.createSession(user, password, false, false, false, false, 0)) {
result = true;
} catch (Exception e) {
// ignore
if (logger.isDebugEnabled()) {
logger.debug("isActive check failed", e);
}
}
return result;