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 #3831

This commit is contained in:
Clebert Suconic 2021-11-01 09:46:19 -04:00
parent c6b85ea4e3 89253b8513
commit e37f2ac05e
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/client/loadbalance/RoundRobinConnectionLoadBalancingPolicy.java
View File

@ -31,17 +31,14 @@ public final class RoundRobinConnectionLoadBalancingPolicy implements Connection
private static final long serialVersionUID = 7511196010141439559L;
private boolean first = true;
private int pos;
private int pos = -1;
@Override
public int select(final int max) {
if (first) {
if (pos == -1) {
// We start on a random one
pos = RandomUtil.randomInterval(0, max);
first = false;
} else {
pos++;