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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
