Repository: activemq-artemis Updated Branches: refs/heads/master 64552367b -> c1bc7a30e
ARTEMIS-1542 - AMQP message cluster-bridging fixi Fixing and issue where AMQP messages would lose their address when being sent accross a cluster-bridge. Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/4ab664f7 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/4ab664f7 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/4ab664f7 Branch: refs/heads/master Commit: 4ab664f796c0c6648a8fe55f58d54cc62b0d849d Parents: 6455236 Author: todd <[email protected]> Authored: Mon Dec 11 11:17:57 2017 -0500 Committer: Clebert Suconic <[email protected]> Committed: Mon Dec 11 12:31:54 2017 -0500 ---------------------------------------------------------------------- .../artemis/core/server/cluster/impl/ClusterConnectionBridge.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/4ab664f7/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/ClusterConnectionBridge.java ---------------------------------------------------------------------- diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/ClusterConnectionBridge.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/ClusterConnectionBridge.java index 5f70d28..7ebc273 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/ClusterConnectionBridge.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/ClusterConnectionBridge.java @@ -182,7 +182,7 @@ public class ClusterConnectionBridge extends BridgeImpl { messageCopy.putExtraBytesProperty(Message.HDR_ROUTE_TO_IDS, queueIds); - messageCopy = super.beforeForward(messageCopy, null); + messageCopy = super.beforeForward(messageCopy, forwardingAddress); return messageCopy; }
