activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dej...@apache.org
Subject svn commit: r1128280 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
Date Fri, 27 May 2011 12:32:15 GMT
Author: dejanb
Date: Fri May 27 12:32:15 2011
New Revision: 1128280

URL: http://svn.apache.org/viewvc?rev=1128280&view=rev
Log:
https://issues.apache.org/jira/browse/AMQ-3135 - ConnectionInfo.clientIp - a correct remote
for duplex

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java?rev=1128280&r1=1128279&r2=1128280&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
Fri May 27 12:32:15 2011
@@ -347,7 +347,7 @@ public abstract class DemandForwardingBr
                 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);



Mime
View raw message