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

ARTEMIS-3811 Cluster connections clashing with ANYCast addresses 

This is a test fix for AMQPClusterReplicaTest
This commit is contained in:
Clebert Suconic 2022-05-03 09:36:25 -04:00 committed by clebertsuconic
parent dbde8c57d8
commit ee51a7806d
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/impl/SimpleAddressManager.java
View File

@ -354,7 +354,7 @@ public class SimpleAddressManager implements AddressManager {
final Bindings bindings = this.mappings.get(addressName); final Bindings bindings = this.mappings.get(addressName);
if (bindings != null) { if (bindings != null) {
for (Binding binding : bindings.getBindings()) { for (Binding binding : bindings.getBindings()) {
if (binding instanceof QueueBinding) { if (binding instanceof QueueBinding && binding.isLocal()) {
final QueueBinding queueBinding = (QueueBinding) binding; final QueueBinding queueBinding = (QueueBinding) binding;
final RoutingType routingType = queueBinding.getQueue().getRoutingType(); final RoutingType routingType = queueBinding.getQueue().getRoutingType();
if (!routingTypes.contains(routingType) && binding.getAddress().equals(addressName)) { if (!routingTypes.contains(routingType) && binding.getAddress().equals(addressName)) {