diff options
| author | Robert Godfrey <rgodfrey@apache.org = rgodfrey = Robert Godfrey rgodfrey@apache.org@apache.org> | 2014-04-11 21:45:28 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org = rgodfrey = Robert Godfrey rgodfrey@apache.org@apache.org> | 2014-04-11 21:45:28 +0000 |
| commit | c9483fa4518774ff016da145ac7bdf96b7fc6f90 (patch) | |
| tree | 0676bce0c8cb3edf1a67c07438edd1297a45a21d /qpid/java/broker-plugins/websocket | |
| parent | 7b703586794bc1e56188f97aca697bd278fc9745 (diff) | |
| download | qpid-python-c9483fa4518774ff016da145ac7bdf96b7fc6f90.tar.gz | |
QPID-5680 : [Java Broker] remove configuration defualt maps
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1586783 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker-plugins/websocket')
2 files changed, 32 insertions, 32 deletions
diff --git a/qpid/java/broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/WebSocketProvider.java b/qpid/java/broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/WebSocketProvider.java index 83e7cff3bd..2b23efc95b 100644 --- a/qpid/java/broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/WebSocketProvider.java +++ b/qpid/java/broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/WebSocketProvider.java @@ -20,38 +20,37 @@ */ package org.apache.qpid.server.transport.websocket; +import java.io.IOException; +import java.net.InetSocketAddress; +import java.net.SocketAddress; +import java.nio.ByteBuffer; +import java.security.Principal; +import java.security.cert.X509Certificate; +import java.util.Collections; +import java.util.Set; + +import javax.net.ssl.SSLContext; +import javax.servlet.http.HttpServletRequest; + +import org.eclipse.jetty.server.Connector; +import org.eclipse.jetty.server.Server; +import org.eclipse.jetty.server.nio.SelectChannelConnector; +import org.eclipse.jetty.server.ssl.SslSelectChannelConnector; +import org.eclipse.jetty.util.ssl.SslContextFactory; +import org.eclipse.jetty.websocket.WebSocket; +import org.eclipse.jetty.websocket.WebSocketHandler; + import org.apache.qpid.protocol.ProtocolEngine; import org.apache.qpid.protocol.ProtocolEngineFactory; import org.apache.qpid.server.model.Broker; import org.apache.qpid.server.model.Port; +import org.apache.qpid.server.model.Protocol; import org.apache.qpid.server.model.Transport; -import org.apache.qpid.server.protocol.AmqpProtocolVersion; import org.apache.qpid.server.protocol.MultiVersionProtocolEngineFactory; import org.apache.qpid.server.transport.AcceptingTransport; import org.apache.qpid.server.util.ServerScopedRuntimeException; -import org.apache.qpid.transport.Binary; import org.apache.qpid.transport.Sender; import org.apache.qpid.transport.network.NetworkConnection; -import org.eclipse.jetty.server.Connector; -import org.eclipse.jetty.server.Server; -import org.eclipse.jetty.server.nio.SelectChannelConnector; -import org.eclipse.jetty.server.ssl.SslSelectChannelConnector; -import org.eclipse.jetty.server.ssl.SslSocketConnector; -import org.eclipse.jetty.util.ssl.SslContextFactory; -import org.eclipse.jetty.websocket.WebSocket; -import org.eclipse.jetty.websocket.WebSocketHandler; - -import javax.net.ssl.SSLContext; -import javax.servlet.http.HttpServletRequest; -import java.io.IOException; -import java.net.InetSocketAddress; -import java.net.SocketAddress; -import java.nio.ByteBuffer; -import java.security.Principal; -import java.security.cert.X509Certificate; -import java.util.Arrays; -import java.util.Collections; -import java.util.Set; class WebSocketProvider implements AcceptingTransport { @@ -59,16 +58,16 @@ class WebSocketProvider implements AcceptingTransport private final Transport _transport; private final SSLContext _sslContext; private final Port<?> _port; - private final Set<AmqpProtocolVersion> _supported; - private final AmqpProtocolVersion _defaultSupportedProtocolReply; + private final Set<Protocol> _supported; + private final Protocol _defaultSupportedProtocolReply; private final ProtocolEngineFactory _factory; private Server _server; WebSocketProvider(final Transport transport, final SSLContext sslContext, final Port<?> port, - final Set<AmqpProtocolVersion> supported, - final AmqpProtocolVersion defaultSupportedProtocolReply) + final Set<Protocol> supported, + final Protocol defaultSupportedProtocolReply) { _transport = transport; _sslContext = sslContext; diff --git a/qpid/java/broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/WebSocketTransportProvider.java b/qpid/java/broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/WebSocketTransportProvider.java index 02d1100315..346e29e212 100644 --- a/qpid/java/broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/WebSocketTransportProvider.java +++ b/qpid/java/broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/WebSocketTransportProvider.java @@ -20,15 +20,16 @@ */ package org.apache.qpid.server.transport.websocket; +import java.util.Set; + +import javax.net.ssl.SSLContext; + import org.apache.qpid.server.model.Port; +import org.apache.qpid.server.model.Protocol; import org.apache.qpid.server.model.Transport; -import org.apache.qpid.server.protocol.AmqpProtocolVersion; import org.apache.qpid.server.transport.AcceptingTransport; import org.apache.qpid.server.transport.TransportProvider; -import javax.net.ssl.SSLContext; -import java.util.Set; - class WebSocketTransportProvider implements TransportProvider { public WebSocketTransportProvider() @@ -39,8 +40,8 @@ class WebSocketTransportProvider implements TransportProvider public AcceptingTransport createTransport(final Set<Transport> transports, final SSLContext sslContext, final Port port, - final Set<AmqpProtocolVersion> supported, - final AmqpProtocolVersion defaultSupportedProtocolReply) + final Set<Protocol> supported, + final Protocol defaultSupportedProtocolReply) { return new WebSocketProvider(transports.iterator().next(), sslContext, |
