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-core | |
| 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-core')
2 files changed, 4 insertions, 1 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/ConnectionAdapter.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/ConnectionAdapter.java index d71c69919d..31668e3bc5 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/ConnectionAdapter.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/ConnectionAdapter.java @@ -130,7 +130,7 @@ public final class ConnectionAdapter extends AbstractConfiguredObject<Connection @Override public String getRemoteProcessPid() { - return null; + return _underlyingConnection.getRemoteProcessPid(); } @Override diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/protocol/AMQConnectionModel.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/protocol/AMQConnectionModel.java index 5d898c3a36..c9045999b9 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/protocol/AMQConnectionModel.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/protocol/AMQConnectionModel.java @@ -75,6 +75,8 @@ public interface AMQConnectionModel<T extends AMQConnectionModel<T,S>, S extends SocketAddress getRemoteAddress(); + String getRemoteProcessPid(); + String getClientId(); String getClientVersion(); @@ -104,4 +106,5 @@ public interface AMQConnectionModel<T extends AMQConnectionModel<T,S>, S extends void addSessionListener(SessionModelListener listener); void removeSessionListener(SessionModelListener listener); + } |