diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2013-05-11 21:10:05 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2013-05-11 21:10:05 +0000 |
| commit | c94310d1133ff26e54fd91b9647940f790ec4585 (patch) | |
| tree | 1545a4f227b54164aa3896790f8fe1db4218bacc /java/broker | |
| parent | 97577a5105594c5526b4bd9b24fa896fc815bc93 (diff) | |
| download | qpid-python-c94310d1133ff26e54fd91b9647940f790ec4585.tar.gz | |
QPID-4833 : [Java Broker] Display transport (TCP/SSL) and (accepting) port for each connection in web management console
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1481416 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker')
3 files changed, 19 insertions, 1 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/model/Connection.java b/java/broker/src/main/java/org/apache/qpid/server/model/Connection.java index aaf6007afd..3139850892 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/model/Connection.java +++ b/java/broker/src/main/java/org/apache/qpid/server/model/Connection.java @@ -78,6 +78,9 @@ public interface Connection extends ConfiguredObject public static final String REMOTE_PROCESS_NAME = "remoteProcessName"; public static final String REMOTE_PROCESS_PID = "remoteProcessPid"; public static final String SESSION_COUNT_LIMIT = "sessionCountLimit"; + public static final String TRANSPORT = "transport"; + public static final String PORT = "port"; + public static final Collection<String> AVAILABLE_ATTRIBUTES = Collections.unmodifiableCollection( @@ -98,7 +101,9 @@ public interface Connection extends ConfiguredObject REMOTE_ADDRESS, REMOTE_PROCESS_NAME, REMOTE_PROCESS_PID, - SESSION_COUNT_LIMIT)); + SESSION_COUNT_LIMIT, + TRANSPORT, + PORT)); //children Collection<Session> getSessions(); diff --git a/java/broker/src/main/java/org/apache/qpid/server/model/adapter/AmqpPortAdapter.java b/java/broker/src/main/java/org/apache/qpid/server/model/adapter/AmqpPortAdapter.java index ddfbf51322..02ff98fb0e 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/model/adapter/AmqpPortAdapter.java +++ b/java/broker/src/main/java/org/apache/qpid/server/model/adapter/AmqpPortAdapter.java @@ -253,4 +253,9 @@ public class AmqpPortAdapter extends PortAdapter return _bindingSocketAddress; } }; + + public String toString() + { + return getName(); + } } diff --git a/java/broker/src/main/java/org/apache/qpid/server/model/adapter/ConnectionAdapter.java b/java/broker/src/main/java/org/apache/qpid/server/model/adapter/ConnectionAdapter.java index 878d4f0034..54a3b634e5 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/model/adapter/ConnectionAdapter.java +++ b/java/broker/src/main/java/org/apache/qpid/server/model/adapter/ConnectionAdapter.java @@ -220,6 +220,14 @@ final class ConnectionAdapter extends AbstractAdapter implements Connection { return _connection.getSessionCountLimit(); } + else if(name.equals(TRANSPORT)) + { + return String.valueOf(_connection.getTransport()); + } + else if(name.equals(PORT)) + { + return String.valueOf(_connection.getPort()); + } return super.getAttribute(name); } |