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

ARTEMIS-5067 Fix ClusteredMirrorSoakTest::testAutoCreateQueue

This commit is contained in:
Clebert Suconic 2024-09-26 10:15:18 -04:00
parent 5bad88e701
commit 5808985a6a
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/mirror/AMQPMirrorControllerSource.java
View File

@ -343,6 +343,11 @@ public class AMQPMirrorControllerSource extends BasicMirrorController<Sender> im
return; return;
} }
if (invalidTarget(context.getMirrorSource(), message)) {
logger.trace("sendMessage::server {} is discarding send to avoid infinite loop (reflection with the mirror)", server);
return;
}
if (ignoreAddress(address)) { if (ignoreAddress(address)) {
logger.trace("sendMessage::server {} is discarding send to address {}, address doesn't match filter", server, address); logger.trace("sendMessage::server {} is discarding send to address {}, address doesn't match filter", server, address);
return; return;