clebertsuconic commented on code in PR #4443:
URL: https://github.com/apache/activemq-artemis/pull/4443#discussion_r1174044880
##########
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/mirror/AMQPMirrorControllerSource.java:
##########
@@ -357,6 +364,13 @@ private static void setProtocolData(MessageReference ref,
String brokerID, long
daMap.put(INTERNAL_DESTINATION, ref.getMessage().getAddress());
}
}
+
+ if (routingContext != null && routingContext.isMirrorIndividualRoute()) {
+ ArrayList<String> queues = new ArrayList<>();
+ routingContext.forEachDurable(q ->
queues.add(String.valueOf(q.getName())));
+ daMap.put(TARGET_QUEUES, queues);
+ }
Review Comment:
non durable queues are not passed along on clustering. this is just for
durable really.
The Mirror Individual Route is to avoid sending a message to an entire fan
out when clustering redistribution happens.
Say you had a clustered message redistribution from one particular queue to
another queue... which is a clustering operation. in that case we need to pass
to the specific queues.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
