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

This closes #658

This commit is contained in:
Clebert Suconic 2016-07-25 14:26:48 -04:00
parent d7c149b416 c9dfbad69c
commit 7a0d3fea22
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ServerLocatorImpl.java
View File

@ -540,7 +540,7 @@ public final class ServerLocatorImpl implements ServerLocatorInternal, Discovery
// if the topologyArray is null, we will use the initialConnectors // if the topologyArray is null, we will use the initialConnectors
if (usedTopology != null) { if (usedTopology != null) {
if (logger.isTraceEnabled()) { if (logger.isTraceEnabled()) {
logger.trace("Selecting connector from toplogy."); logger.trace("Selecting connector from topology.");
} }
int pos = loadBalancingPolicy.select(usedTopology.length); int pos = loadBalancingPolicy.select(usedTopology.length);
Pair<TransportConfiguration, TransportConfiguration> pair = usedTopology[pos]; Pair<TransportConfiguration, TransportConfiguration> pair = usedTopology[pos];
@ -1844,7 +1844,7 @@ public final class ServerLocatorImpl implements ServerLocatorInternal, Discovery
return clone; return clone;
} }
public boolean isReceivedToplogy() { public boolean isReceivedTopology() {
return receivedTopology; return receivedTopology;
} }

2
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQClusteredTest.java
View File

@ -145,7 +145,7 @@ public class ActiveMQClusteredTest extends ActiveMQRAClusteredTestBase {
long timeout = 10000; long timeout = 10000;
long now = System.currentTimeMillis(); long now = System.currentTimeMillis();
while (!((ServerLocatorImpl)cf1.getServerLocator()).isReceivedToplogy()) { while (!((ServerLocatorImpl)cf1.getServerLocator()).isReceivedTopology()) {
Thread.sleep(50); Thread.sleep(50);
} }