summaryrefslogtreecommitdiff
path: root/qpid/java/broker-plugins/websocket/src
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2015-01-31 20:07:36 +0000
committerRobert Godfrey <rgodfrey@apache.org>2015-01-31 20:07:36 +0000
commit26eab7ed4556717fca50ad93025fdc8d112f9715 (patch)
treec4019683f17a8ec570786ff067a0d261c5c603e0 /qpid/java/broker-plugins/websocket/src
parentaef6c73485912be3be3d9bc60bb9671c951368c6 (diff)
downloadqpid-python-26eab7ed4556717fca50ad93025fdc8d112f9715.tar.gz
Separate Byte and ProtocolEvent sender/receivers, add server specific 0-10 encoder
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1656248 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker-plugins/websocket/src')
-rw-r--r--qpid/java/broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/WebSocketProvider.java6
1 files changed, 3 insertions, 3 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 940e24d7cf..896a7119f7 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
@@ -53,7 +53,7 @@ import org.apache.qpid.server.model.port.AmqpPort;
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.Sender;
+import org.apache.qpid.transport.ByteBufferSender;
import org.apache.qpid.transport.network.NetworkConnection;
import org.apache.qpid.transport.network.security.ssl.SSLUtil;
@@ -240,7 +240,7 @@ class WebSocketProvider implements AcceptingTransport
}
}
- private class ConnectionWrapper implements NetworkConnection, Sender<ByteBuffer>
+ private class ConnectionWrapper implements NetworkConnection, ByteBufferSender
{
private final WebSocket.Connection _connection;
private final SocketAddress _localAddress;
@@ -259,7 +259,7 @@ class WebSocketProvider implements AcceptingTransport
}
@Override
- public Sender<ByteBuffer> getSender()
+ public ByteBufferSender getSender()
{
return this;
}