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;
+ }
}