Modifier and Type | Method and Description |
---|---|
WebSocketChannel |
WebSocket13ClientHandshake.createChannel(org.xnio.StreamConnection channel,
String wsUri,
org.xnio.Pool<ByteBuffer> bufferPool) |
abstract WebSocketChannel |
WebSocketClientHandshake.createChannel(org.xnio.StreamConnection channel,
String wsUri,
org.xnio.Pool<ByteBuffer> bufferPool) |
Modifier and Type | Method and Description |
---|---|
static org.xnio.IoFuture<WebSocketChannel> |
WebSocketClient.connect(org.xnio.XnioWorker worker,
org.xnio.Pool<ByteBuffer> bufferPool,
org.xnio.OptionMap optionMap,
URI uri,
WebSocketVersion version) |
Modifier and Type | Field and Description |
---|---|
protected WebSocketChannel |
StreamSinkFrameChannel.wsChannel |
protected WebSocketChannel |
StreamSourceFrameChannel.wsChannel |
Modifier and Type | Method and Description |
---|---|
WebSocketChannel |
StreamSinkFrameChannel.getWebSocketChannel() |
WebSocketChannel |
StreamSourceFrameChannel.getWebSocketChannel() |
WebSocketChannel |
FragmentedMessageChannel.getWebSocketChannel() |
Modifier and Type | Method and Description |
---|---|
org.xnio.ChannelListener.Setter<? extends WebSocketChannel> |
WebSocketChannel.getCloseSetter() |
org.xnio.ChannelListener.Setter<WebSocketChannel> |
WebSocketChannel.getReceiveSetter()
Return the
ChannelListener.Setter which will holds the ChannelListener that gets notified once a frame was
received. |
Modifier and Type | Method and Description |
---|---|
void |
WebSocketCallback.complete(WebSocketChannel channel,
T context) |
static void |
WebSocketUtils.echoFrame(WebSocketChannel channel,
StreamSourceFrameChannel ws)
Echo back the frame to the sender
|
void |
AbstractReceiveListener.handleEvent(WebSocketChannel channel) |
protected void |
AbstractReceiveListener.onBinary(WebSocketChannel webSocketChannel,
StreamSourceFrameChannel messageChannel) |
protected void |
AbstractReceiveListener.onClose(WebSocketChannel webSocketChannel,
StreamSourceFrameChannel channel) |
protected void |
AbstractReceiveListener.onContinuation(WebSocketChannel webSocketChannel,
StreamSourceFrameChannel messageChannel) |
protected void |
AbstractReceiveListener.onError(WebSocketChannel channel,
Throwable error) |
void |
WebSocketCallback.onError(WebSocketChannel channel,
T context,
Throwable throwable) |
protected void |
AbstractReceiveListener.onFullBinaryMessage(WebSocketChannel channel,
BufferedBinaryMessage message) |
protected void |
AbstractReceiveListener.onFullCloseMessage(WebSocketChannel channel,
BufferedBinaryMessage message) |
protected void |
AbstractReceiveListener.onFullPingMessage(WebSocketChannel channel,
BufferedBinaryMessage message) |
protected void |
AbstractReceiveListener.onFullPongMessage(WebSocketChannel channel,
BufferedBinaryMessage message) |
protected void |
AbstractReceiveListener.onFullTextMessage(WebSocketChannel channel,
BufferedTextMessage message) |
protected void |
AbstractReceiveListener.onPing(WebSocketChannel webSocketChannel,
StreamSourceFrameChannel channel) |
protected void |
AbstractReceiveListener.onPong(WebSocketChannel webSocketChannel,
StreamSourceFrameChannel messageChannel) |
protected void |
AbstractReceiveListener.onText(WebSocketChannel webSocketChannel,
StreamSourceFrameChannel messageChannel) |
static void |
WebSockets.sendBinary(ByteBuffer[] data,
WebSocketChannel wsChannel,
WebSocketCallback<Void> callback)
Sends a complete text message, invoking the callback when complete
|
static void |
WebSockets.sendBinary(ByteBuffer data,
WebSocketChannel wsChannel,
WebSocketCallback<Void> callback)
Sends a complete text message, invoking the callback when complete
|
static void |
WebSockets.sendBinaryBlocking(ByteBuffer[] data,
WebSocketChannel wsChannel)
Sends a complete text message, invoking the callback when complete
|
static void |
WebSockets.sendBinaryBlocking(ByteBuffer data,
WebSocketChannel wsChannel)
Sends a complete text message, invoking the callback when complete
|
static void |
WebSockets.sendClose(ByteBuffer[] data,
WebSocketChannel wsChannel,
WebSocketCallback<Void> callback)
Sends a complete close message, invoking the callback when complete
|
static void |
WebSockets.sendClose(ByteBuffer data,
WebSocketChannel wsChannel,
WebSocketCallback<Void> callback)
Sends a complete close message, invoking the callback when complete
|
static void |
WebSockets.sendCloseBlocking(ByteBuffer[] data,
WebSocketChannel wsChannel)
Sends a complete close message, invoking the callback when complete
|
static void |
WebSockets.sendCloseBlocking(ByteBuffer data,
WebSocketChannel wsChannel)
Sends a complete close message, invoking the callback when complete
|
static void |
WebSockets.sendPing(ByteBuffer[] data,
WebSocketChannel wsChannel,
WebSocketCallback<Void> callback)
Sends a complete ping message, invoking the callback when complete
|
static void |
WebSockets.sendPing(ByteBuffer data,
WebSocketChannel wsChannel,
WebSocketCallback<Void> callback)
Sends a complete ping message, invoking the callback when complete
|
static void |
WebSockets.sendPingBlocking(ByteBuffer[] data,
WebSocketChannel wsChannel)
Sends a complete ping message using blocking IO
|
static void |
WebSockets.sendPingBlocking(ByteBuffer data,
WebSocketChannel wsChannel)
Sends a complete ping message using blocking IO
|
static void |
WebSockets.sendPong(ByteBuffer[] data,
WebSocketChannel wsChannel,
WebSocketCallback<Void> callback)
Sends a complete pong message, invoking the callback when complete
|
static void |
WebSockets.sendPong(ByteBuffer data,
WebSocketChannel wsChannel,
WebSocketCallback<Void> callback)
Sends a complete pong message, invoking the callback when complete
|
static void |
WebSockets.sendPongBlocking(ByteBuffer[] data,
WebSocketChannel wsChannel)
Sends a complete pong message using blocking IO
|
static void |
WebSockets.sendPongBlocking(ByteBuffer data,
WebSocketChannel wsChannel)
Sends a complete pong message using blocking IO
|
static void |
WebSockets.sendText(String message,
WebSocketChannel wsChannel,
WebSocketCallback<Void> callback)
Sends a complete text message, invoking the callback when complete
|
static void |
WebSockets.sendTextBlocking(String message,
WebSocketChannel wsChannel)
Sends a complete text message, invoking the callback when complete
|
Constructor and Description |
---|
FixedPayloadFrameSourceChannel(WebSocketChannel.StreamSourceChannelControl streamSourceChannelControl,
org.xnio.channels.StreamSourceChannel channel,
WebSocketChannel wsChannel,
WebSocketFrameType type,
long payloadSize,
int rsv,
boolean finalFragment,
ChannelFunction... functions) |
StreamSinkFrameChannel(org.xnio.channels.StreamSinkChannel channel,
WebSocketChannel wsChannel,
WebSocketFrameType type,
long payloadSize) |
StreamSourceFrameChannel(WebSocketChannel.StreamSourceChannelControl streamSourceChannelControl,
org.xnio.channels.StreamSourceChannel channel,
WebSocketChannel wsChannel,
WebSocketFrameType type,
long payloadSize) |
StreamSourceFrameChannel(WebSocketChannel.StreamSourceChannelControl streamSourceChannelControl,
org.xnio.channels.StreamSourceChannel channel,
WebSocketChannel wsChannel,
WebSocketFrameType type,
long payloadSize,
int rsv,
boolean finalFragment) |
Modifier and Type | Method and Description |
---|---|
void |
WebSocketConnectionCallback.onConnect(WebSocketHttpExchange exchange,
WebSocketChannel channel)
Is called once the WebSocket connection is established, which means the handshake was successful.
|
Modifier and Type | Method and Description |
---|---|
abstract WebSocketChannel |
Handshake.createChannel(WebSocketHttpExchange exchange,
org.xnio.StreamConnection channel,
org.xnio.Pool<ByteBuffer> pool)
Create the
WebSocketChannel from the HttpServerExchange |
Modifier and Type | Class and Description |
---|---|
class |
WebSocket00Channel
WebSocketChannel which is used for WebSocketVersion.V00 |
Modifier and Type | Method and Description |
---|---|
WebSocketChannel |
Hybi00Handshake.createChannel(WebSocketHttpExchange exchange,
org.xnio.StreamConnection channel,
org.xnio.Pool<ByteBuffer> pool) |
Modifier and Type | Class and Description |
---|---|
class |
WebSocket07Channel
WebSocketChannel which is used for WebSocketVersion.V08 |
Modifier and Type | Method and Description |
---|---|
WebSocketChannel |
Hybi07Handshake.createChannel(WebSocketHttpExchange exchange,
org.xnio.StreamConnection channel,
org.xnio.Pool<ByteBuffer> pool) |
Modifier and Type | Class and Description |
---|---|
class |
WebSocket08Channel
WebSocketChannel which is used for WebSocketVersion.V08 |
Modifier and Type | Method and Description |
---|---|
WebSocketChannel |
Hybi08Handshake.createChannel(WebSocketHttpExchange exchange,
org.xnio.StreamConnection channel,
org.xnio.Pool<ByteBuffer> pool) |
Modifier and Type | Class and Description |
---|---|
class |
WebSocket13Channel
A WebSocketChannel that handles version 13
|
Modifier and Type | Method and Description |
---|---|
WebSocketChannel |
Hybi13Handshake.createChannel(WebSocketHttpExchange exchange,
org.xnio.StreamConnection channel,
org.xnio.Pool<ByteBuffer> pool) |
Modifier and Type | Method and Description |
---|---|
WebSocketChannel |
UndertowSession.getWebSocketChannel() |
Modifier and Type | Method and Description |
---|---|
void |
ServerWebSocketContainer.invokeEndpointMethod(WebSocketChannel channel,
Runnable invocation)
Runs a web socket invocation, setting up the threads and dispatching a thread pool
Unfortunately we need to dispatch to a thread pool, because there is a good chance that the endpoint
will use blocking IO methods.
|
void |
EndpointSessionHandler.onConnect(WebSocketHttpExchange exchange,
WebSocketChannel channel) |
Modifier and Type | Method and Description |
---|---|
void |
UndertowSession.setReceiveListener(org.xnio.ChannelListener<WebSocketChannel> handler)
sets the recieve listener This should only be used for annotated endpoints.
|
Constructor and Description |
---|
UndertowSession(WebSocketChannel webSocketChannel,
URI requestUri,
Map<String,String> pathParameters,
Map<String,List<String>> requestParameterMap,
EndpointSessionHandler handler,
Principal user,
InstanceHandle<javax.websocket.Endpoint> endpoint,
javax.websocket.EndpointConfig config,
String queryString,
Encoding encoding,
Set<javax.websocket.Session> openSessions) |
Modifier and Type | Method and Description |
---|---|
WebSocketChannel |
JsrHybi13Handshake.createChannel(WebSocketHttpExchange exchange,
org.xnio.StreamConnection c,
org.xnio.Pool<ByteBuffer> buffers) |
WebSocketChannel |
JsrHybi07Handshake.createChannel(WebSocketHttpExchange exchange,
org.xnio.StreamConnection c,
org.xnio.Pool<ByteBuffer> buffers) |
WebSocketChannel |
JsrHybi08Handshake.createChannel(WebSocketHttpExchange exchange,
org.xnio.StreamConnection c,
org.xnio.Pool<ByteBuffer> buffers) |
Modifier and Type | Method and Description |
---|---|
static ConfiguredServerEndpoint |
HandshakeUtil.getConfig(WebSocketChannel channel)
Returns the
ServerEndpointConfiguration which was used while create the WebSocketChannel . |
static void |
HandshakeUtil.setConfig(WebSocketChannel channel,
ConfiguredServerEndpoint config)
Set the
ServerEndpointConfiguration which is used to create the WebSocketChannel . |
Copyright © 2013 JBoss by Red Hat. All rights reserved.