You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by de...@apache.org on 2011/05/16 12:17:15 UTC

svn commit: r1103673 - in /activemq/trunk/activemq-core/src/main/java/org/apache/activemq: broker/TransportConnection.java command/ConnectionInfo.java

Author: dejanb
Date: Mon May 16 10:17:14 2011
New Revision: 1103673

URL: http://svn.apache.org/viewvc?rev=1103673&view=rev
Log:
https://issues.apache.org/jira/browse/AMQ-3135 - add remote address to connection info advisory

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionInfo.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java?rev=1103673&r1=1103672&r2=1103673&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java Mon May 16 10:17:14 2011
@@ -687,6 +687,7 @@ public class TransportConnection impleme
         this.manageable = info.isManageable();
         state.setContext(context);
         state.setConnection(this);
+        info.setClientIp(getRemoteAddress());
        
         try {
             broker.addConnection(context, info);

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionInfo.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionInfo.java?rev=1103673&r1=1103672&r2=1103673&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionInfo.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionInfo.java Mon May 16 10:17:14 2011
@@ -29,6 +29,7 @@ public class ConnectionInfo extends Base
 
     protected ConnectionId connectionId;
     protected String clientId;
+    protected String clientIp;
     protected String userName;
     protected String password;
     protected BrokerId[] brokerPath;
@@ -68,6 +69,7 @@ public class ConnectionInfo extends Base
         copy.clientMaster = clientMaster;
         copy.transportContext = transportContext;
         copy.faultTolerant= faultTolerant;
+        copy.clientIp = clientIp;
     }
 
     /**
@@ -228,4 +230,12 @@ public class ConnectionInfo extends Base
     public void setFailoverReconnect(boolean failoverReconnect) {
         this.failoverReconnect = failoverReconnect;
     }
+
+    public String getClientIp() {
+        return clientIp;
+    }
+
+    public void setClientIp(String clientIp) {
+        this.clientIp = clientIp;
+    }
 }