public final class ProtocolHandler extends Object
Modifier and Type | Field and Description |
---|---|
static int |
MASK_SIZE
RFC 6455
|
Modifier and Type | Method and Description |
---|---|
Future<Frame> |
close(int code,
String reason) |
Handshake |
handshake(TyrusEndpointWrapper endpointWrapper,
UpgradeRequest request,
UpgradeResponse response,
ExtendedExtension.ExtensionContext extensionContext)
Server side handshake processing.
|
boolean |
hasExtensions()
Returns true when current connection has some negotiated extension.
|
void |
process(Frame frame,
TyrusWebSocket socket)
TODO.
|
Future<Frame> |
send(byte[] data) |
void |
send(byte[] data,
javax.websocket.SendHandler handler) |
Future<Frame> |
send(String data) |
void |
send(String data,
javax.websocket.SendHandler handler) |
Future<Frame> |
sendRawFrame(ByteBuffer data)
Raw frame is always whole (not partial).
|
void |
setExtensionContext(ExtendedExtension.ExtensionContext extensionContext)
Client side.
|
void |
setExtensions(List<javax.websocket.Extension> extensions)
Client side.
|
void |
setMessageEventListener(MessageEventListener messageEventListener)
Set message event listener.
|
void |
setWebSocket(TyrusWebSocket webSocket)
Client side.
|
void |
setWriter(Writer writer)
Set
Writer instance. |
Future<Frame> |
stream(boolean last,
byte[] bytes,
int off,
int len) |
Future<Frame> |
stream(boolean last,
String fragment) |
Frame |
unframe(ByteBuffer buffer)
TODO!
|
public static final int MASK_SIZE
public void setWriter(Writer writer)
Writer
instance.
The set instance is used for "sending" all outgoing WebSocket frames.writer
- Writer
to be set.public boolean hasExtensions()
true
if there is at least one negotiated extension associated to this connection, false
otherwise.public Handshake handshake(TyrusEndpointWrapper endpointWrapper, UpgradeRequest request, UpgradeResponse response, ExtendedExtension.ExtensionContext extensionContext) throws HandshakeException
endpointWrapper
- endpoint related to the handshake (path is already matched).request
- handshake request.response
- handshake response.extensionContext
- extension context.HandshakeException
- when there is problem with received UpgradeRequest
.public void setExtensions(List<javax.websocket.Extension> extensions)
extensions
- list of negotiated extensions. Can be null
.public void setWebSocket(TyrusWebSocket webSocket)
webSocket
- client WebSocket connection.public void setExtensionContext(ExtendedExtension.ExtensionContext extensionContext)
extensionContext
- extension context.public void setMessageEventListener(MessageEventListener messageEventListener)
messageEventListener
- message event listener.public void send(byte[] data, javax.websocket.SendHandler handler)
public void send(String data, javax.websocket.SendHandler handler)
public Future<Frame> sendRawFrame(ByteBuffer data)
data
- serialized frame.public Frame unframe(ByteBuffer buffer)
buffer
- TODO.public void process(Frame frame, TyrusWebSocket socket)
frame
- TODO.socket
- TODO.Copyright © 2012-2015, Oracle and/or its affiliates. All Rights Reserved. Use is subject to license terms.