You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2024/09/26 14:15:58 UTC
(activemq-artemis) branch main updated: ARTEMIS-5067 Fix ClusteredMirrorSoakTest::testAutoCreateQueue
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 5808985a6a ARTEMIS-5067 Fix ClusteredMirrorSoakTest::testAutoCreateQueue
5808985a6a is described below
commit 5808985a6a11ffb137b2146c63c4845f61fd15c5
Author: Clebert Suconic <cl...@apache.org>
AuthorDate: Thu Sep 26 10:15:18 2024 -0400
ARTEMIS-5067 Fix ClusteredMirrorSoakTest::testAutoCreateQueue
---
.../protocol/amqp/connect/mirror/AMQPMirrorControllerSource.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/mirror/AMQPMirrorControllerSource.java b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/mirror/AMQPMirrorControllerSource.java
index 48cdfb3bc5..0d31363c6f 100644
--- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/mirror/AMQPMirrorControllerSource.java
+++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/mirror/AMQPMirrorControllerSource.java
@@ -343,6 +343,11 @@ public class AMQPMirrorControllerSource extends BasicMirrorController<Sender> im
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)) {
logger.trace("sendMessage::server {} is discarding send to address {}, address doesn't match filter", server, address);
return;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@activemq.apache.org
For additional commands, e-mail: commits-help@activemq.apache.org
For further information, visit: https://activemq.apache.org/contact