diff options
| author | Keith Wall <kwall@apache.org> | 2014-08-03 18:06:09 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2014-08-03 18:06:09 +0000 |
| commit | 50ef5c1742d607847dc0e5080278bcdd7e84b69a (patch) | |
| tree | a24069745efbcb268fae366515944132016dbea3 /qpid/java/broker-plugins/amqp-0-10-protocol | |
| parent | 20beab35b19f246a88ec79828f788e512628252c (diff) | |
| download | qpid-python-50ef5c1742d607847dc0e5080278bcdd7e84b69a.tar.gz | |
QPID-5958: [Java Broker] Wire up the Connection#remoteProcessPid attribute to the client's process identifier made
available as connection properties during connection negotiation.
* Make information available via the Connection tab during the Web Management UI.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1615425 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker-plugins/amqp-0-10-protocol')
2 files changed, 11 insertions, 0 deletions
diff --git a/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerConnection.java b/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerConnection.java index ede51ef213..2ad79ad980 100644 --- a/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerConnection.java +++ b/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerConnection.java @@ -507,6 +507,12 @@ public class ServerConnection extends Connection implements AMQConnectionModel<S } @Override + public String getRemoteProcessPid() + { + return getConnectionDelegate().getRemoteProcessPid(); + } + + @Override public void closed() { performDeleteTasks(); diff --git a/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerConnectionDelegate.java b/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerConnectionDelegate.java index 390d7a8c46..7751ff765d 100644 --- a/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerConnectionDelegate.java +++ b/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerConnectionDelegate.java @@ -367,6 +367,11 @@ public class ServerConnectionDelegate extends ServerDelegate return _clientProperties == null ? null : (String) _clientProperties.get(ConnectionStartProperties.PRODUCT); } + public String getRemoteProcessPid() + { + return (_clientProperties == null || _clientProperties.get(ConnectionStartProperties.PID) == null) ? null : String.valueOf(_clientProperties.get(ConnectionStartProperties.PID)); + } + @Override protected int getHeartbeatMax() { |