ARTEMIS-3753 Small Improvement on RouterContext.internalOnly calculation

This commit is contained in:
Clebert Suconic 2022-04-23 11:17:24 -04:00
parent a38fae1fbd
commit 28513e048f
2 changed files with 6 additions and 6 deletions

View File

@ -177,11 +177,11 @@ public class RoutingContextImpl implements RoutingContext {
} }
if (internalOnly == null) { if (internalOnly == null) {
internalOnly = true; internalOnly = queue.isInternalQueue();
} } else {
// every queue added has to be internal only // every queue added has to be internal only
internalOnly = internalOnly && queue.isInternalQueue(); internalOnly = internalOnly && queue.isInternalQueue();
}
queueCount++; queueCount++;
} }

View File

@ -121,11 +121,11 @@ public class AMQPClusterReplicaTest extends AmqpClientTestSupport {
producer.send(session.createTextMessage("hello")); producer.send(session.createTextMessage("hello"));
} }
org.apache.activemq.artemis.core.server.Queue mainServerQueue = server.locateQueue("test");
org.apache.activemq.artemis.core.server.Queue node1Queue = node_1.locateQueue("test"); org.apache.activemq.artemis.core.server.Queue node1Queue = node_1.locateQueue("test");
org.apache.activemq.artemis.core.server.Queue node2Queue = node_2.locateQueue("test");
Wait.assertEquals(10L, node1Queue::getMessageCount, 5000, 10); Wait.assertEquals(10L, node1Queue::getMessageCount, 5000, 10);
connection.close();
} }
} }