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

ARTEMIS-3670 Fixing Divert Update tests

This commit is contained in:
Clebert Suconic 2022-02-06 11:42:03 -05:00
parent fac9837a2f
commit 100e4abd7b
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-server/src/main/java/org/apache/activemq/artemis/core/server/impl/DivertImpl.java
View File

@ -41,7 +41,7 @@ public class DivertImpl implements Divert {
private volatile SimpleString forwardAddress;
private final SimpleString[] forwardAddresses;
private volatile SimpleString[] forwardAddresses;
private final SimpleString uniqueName;
@ -69,13 +69,7 @@ public class DivertImpl implements Divert {
final ComponentConfigurationRoutingType routingType) {
this.address = address;
this.forwardAddress = forwardAddress;
String[] split = forwardAddress.toString().split(",");
forwardAddresses = new SimpleString[split.length];
for (int i = 0; i < split.length; i++) {
forwardAddresses[i] = new SimpleString(split[i].trim());
}
this.setForwardAddress(forwardAddress);
this.uniqueName = uniqueName;
@ -206,6 +200,14 @@ public class DivertImpl implements Divert {
@Override
public void setForwardAddress(SimpleString forwardAddress) {
this.forwardAddress = forwardAddress;
String[] split = forwardAddress.toString().split(",");
SimpleString[] forwardAddresses = new SimpleString[split.length];
for (int i = 0; i < split.length; i++) {
forwardAddresses[i] = new SimpleString(split[i].trim());
}
this.forwardAddresses = forwardAddresses;
}
@Override