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

ARTEMIS-2074 Fixing Covery scan findings

This commit is contained in:
Clebert Suconic 2018-09-12 17:55:04 -04:00
parent 576f67c7c2
commit 25a7d3bffc
1 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQConnectionFactory.java
View File

@ -67,14 +67,6 @@ public class ActiveMQConnectionFactory extends JNDIStorable implements Connectio
private static final long serialVersionUID = 6730844785641767519L; private static final long serialVersionUID = 6730844785641767519L;
public void setUseTopologyForLoadBalancing(boolean useTopologyForLoadBalancing) {
serverLocator.setUseTopologyForLoadBalancing(useTopologyForLoadBalancing);
}
public boolean isUseTopologyForLoadBalancing() {
return serverLocator.getUseTopologyForLoadBalancing();
}
private ServerLocator serverLocator; private ServerLocator serverLocator;
private String clientID; private String clientID;
@ -543,6 +535,16 @@ public class ActiveMQConnectionFactory extends JNDIStorable implements Connectio
serverLocator.setCallFailoverTimeout(callTimeout); serverLocator.setCallFailoverTimeout(callTimeout);
} }
public synchronized void setUseTopologyForLoadBalancing(boolean useTopologyForLoadBalancing) {
checkWrite();
serverLocator.setUseTopologyForLoadBalancing(useTopologyForLoadBalancing);
}
public synchronized boolean isUseTopologyForLoadBalancing() {
checkWrite();
return serverLocator.getUseTopologyForLoadBalancing();
}
public synchronized int getConsumerWindowSize() { public synchronized int getConsumerWindowSize() {
return serverLocator.getConsumerWindowSize(); return serverLocator.getConsumerWindowSize();
} }