Repository: activemq-artemis Updated Branches: refs/heads/master addfef219 -> f1608d724
ARTEMIS-1589 ActiveMQProtonRemotingConnection#getClientID() now returns remote client Id instead of server client Id Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/3334863e Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/3334863e Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/3334863e Branch: refs/heads/master Commit: 3334863e81d778be3a4137b8b2ab096de2341c9c Parents: addfef2 Author: jostbg <[email protected]> Authored: Thu Jan 11 12:23:33 2018 +0100 Committer: Timothy Bish <[email protected]> Committed: Wed Jan 17 16:54:43 2018 -0500 ---------------------------------------------------------------------- .../protocol/amqp/broker/ActiveMQProtonRemotingConnection.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3334863e/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/ActiveMQProtonRemotingConnection.java ---------------------------------------------------------------------- diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/ActiveMQProtonRemotingConnection.java b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/ActiveMQProtonRemotingConnection.java index 79144d1..02f035a 100644 --- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/ActiveMQProtonRemotingConnection.java +++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/ActiveMQProtonRemotingConnection.java @@ -173,7 +173,7 @@ public class ActiveMQProtonRemotingConnection extends AbstractRemotingConnection @Override public String getClientID() { - return amqpConnection.getContainer(); + return amqpConnection.getRemoteContainer(); } public void open() {
