[activemq-artemis] branch main updated: ARTEMIS-3811 Cluster connections clashing with ANYCast addresses

[clebertsuconic]

This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/main by this push:
     new ee51a7806d ARTEMIS-3811 Cluster connections clashing with ANYCast 
addresses
ee51a7806d is described below

commit ee51a7806da5f258dbb1ed56271c56d3e992383b
Author: Clebert Suconic <clebertsuco...@apache.org>
AuthorDate: Tue May 3 09:36:25 2022 -0400

    ARTEMIS-3811 Cluster connections clashing with ANYCast addresses
    
    This is a test fix for AMQPClusterReplicaTest
---
 .../activemq/artemis/core/postoffice/impl/SimpleAddressManager.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/impl/SimpleAddressManager.java
 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/impl/SimpleAddressManager.java
index 2e923008e9..0182c34e9b 100644
--- 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/impl/SimpleAddressManager.java
+++ 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/postoffice/impl/SimpleAddressManager.java
@@ -354,7 +354,7 @@ public class SimpleAddressManager implements AddressManager 
{
       final Bindings bindings = this.mappings.get(addressName);
       if (bindings != null) {
          for (Binding binding : bindings.getBindings()) {
-            if (binding instanceof QueueBinding) {
+            if (binding instanceof QueueBinding && binding.isLocal()) {
                final QueueBinding queueBinding = (QueueBinding) binding;
                final RoutingType routingType = 
queueBinding.getQueue().getRoutingType();
                if (!routingTypes.contains(routingType) && 
binding.getAddress().equals(addressName)) {