gemmellr commented on code in PR #4443:
URL: https://github.com/apache/activemq-artemis/pull/4443#discussion_r1176363772
##########
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/mirror/AMQPMirrorControllerSource.java:
##########
@@ -76,14 +77,20 @@ public class AMQPMirrorControllerSource extends
BasicMirrorController<Sender> im
public static final Symbol INTERNAL_ID =
Symbol.getSymbol("x-opt-amq-mr-id");
public static final Symbol INTERNAL_DESTINATION =
Symbol.getSymbol("x-opt-amq-mr-dst");
+ /** When a clustered node (from regular cluster connections) receives a
message
+ it will have target queues associated with it
+ this could be from message redistribution or simply load balancing.
+ an that case this will have the queue associated with it */
+ public static final Symbol TARGET_QUEUES =
Symbol.getSymbol("x-opt-amq-trg-q");
Review Comment:
Somehow I missed your other PR yesterday, even though I did look for a
commit/PR first...unsure how I didnt see it.
--
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]
