summaryrefslogtreecommitdiff
path: root/qpid/java/broker-plugins/management-http/src/main
diff options
context:
space:
mode:
authorKeith Wall <kwall@apache.org>2015-04-10 09:57:39 +0000
committerKeith Wall <kwall@apache.org>2015-04-10 09:57:39 +0000
commit60c56cbf7bf8afd5dc577480853e7214cb60b3e2 (patch)
tree472e786d636fd51ae12ea0061596ec7e0b64d811 /qpid/java/broker-plugins/management-http/src/main
parentb187311574bbf087f376256d237173b38a84fdbc (diff)
downloadqpid-python-60c56cbf7bf8afd5dc577480853e7214cb60b3e2.tar.gz
QPID-6485: [Java Broker] Remove superfluous find/get methods from the Broker configured object
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1672602 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker-plugins/management-http/src/main')
-rw-r--r--qpid/java/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/HttpManagement.java14
1 files changed, 13 insertions, 1 deletions
diff --git a/qpid/java/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/HttpManagement.java b/qpid/java/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/HttpManagement.java
index 4639236d60..f9293a33b0 100644
--- a/qpid/java/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/HttpManagement.java
+++ b/qpid/java/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/HttpManagement.java
@@ -22,6 +22,7 @@ package org.apache.qpid.server.management.plugin;
import java.io.IOException;
import java.io.Writer;
+import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.security.GeneralSecurityException;
import java.util.ArrayList;
@@ -556,7 +557,18 @@ public class HttpManagement extends AbstractPluginAdapter<HttpManagement> implem
@Override
public AuthenticationProvider getAuthenticationProvider(SocketAddress localAddress)
{
- return getBroker().getAuthenticationProvider(localAddress);
+ InetSocketAddress inetSocketAddress = (InetSocketAddress)localAddress;
+ AuthenticationProvider provider = null;
+ Collection<Port<?>> ports = getBroker().getPorts();
+ for (Port<?> p : ports)
+ {
+ if (p instanceof HttpPort && inetSocketAddress.getPort() == p.getPort())
+ {
+ provider = ((HttpPort<?>) p).getAuthenticationProvider();
+ break;
+ }
+ }
+ return provider;
}
@Override