From 861e26c2975fd844db6aa550df8c9d1759d345f0 Mon Sep 17 00:00:00 2001 From: Bosanac Dejan Date: Fri, 27 May 2011 12:32:15 +0000 Subject: [PATCH] https://issues.apache.org/jira/browse/AMQ-3135 - ConnectionInfo.clientIp - a correct remote for duplex git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1128280 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/activemq/network/DemandForwardingBridgeSupport.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java b/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java index f1df2988a7..aa56a09b2f 100644 --- a/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java +++ b/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java @@ -347,7 +347,7 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br remoteConnectionInfo.setClientId(configuration.getName() + "_" + configuration.getBrokerName() + "_outbound"); remoteConnectionInfo.setUserName(configuration.getUserName()); remoteConnectionInfo.setPassword(configuration.getPassword()); - remoteConnectionInfo.setClientIp(remoteBroker.getRemoteAddress()); + remoteConnectionInfo.setClientIp(remoteBroker.toString()); remoteBroker.oneway(remoteConnectionInfo); SessionInfo remoteSessionInfo = new SessionInfo(remoteConnectionInfo, 1);