summaryrefslogtreecommitdiff
path: root/qpid/java/broker-plugins/websocket
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org = rgodfrey = Robert Godfrey rgodfrey@apache.org@apache.org>2014-04-11 21:45:28 +0000
committerRobert Godfrey <rgodfrey@apache.org = rgodfrey = Robert Godfrey rgodfrey@apache.org@apache.org>2014-04-11 21:45:28 +0000
commitc9483fa4518774ff016da145ac7bdf96b7fc6f90 (patch)
tree0676bce0c8cb3edf1a67c07438edd1297a45a21d /qpid/java/broker-plugins/websocket
parent7b703586794bc1e56188f97aca697bd278fc9745 (diff)
downloadqpid-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')
-rw-r--r--qpid/java/broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/WebSocketProvider.java51
-rw-r--r--qpid/java/broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/WebSocketTransportProvider.java13
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,