Modifier and Type | Method and Description |
---|---|
Set<WebSocketChannel> |
ServletWebSocketHttpExchange.getPeerConnections() |
Constructor and Description |
---|
ServletWebSocketHttpExchange(HttpServletRequest request,
HttpServletResponse response,
Set<WebSocketChannel> peerConnections) |
Modifier and Type | Method and Description |
---|---|
Set<WebSocketChannel> |
WebSocketProtocolHandshakeHandler.getPeerConnections() |
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 |
WebSocketClientHandshake.createChannel(StreamConnection channel,
String wsUri,
ByteBufferPool bufferPool,
OptionMap options) |
WebSocketChannel |
WebSocket13ClientHandshake.createChannel(StreamConnection channel,
String wsUri,
ByteBufferPool bufferPool,
OptionMap options) |
Modifier and Type | Method and Description |
---|---|
IoFuture<WebSocketChannel> |
WebSocketClient.ConnectionBuilder.connect() |
static IoFuture<WebSocketChannel> |
WebSocketClient.connect(XnioWorker worker,
ByteBufferPool bufferPool,
OptionMap optionMap,
URI uri,
WebSocketVersion version)
Deprecated.
|
static IoFuture<WebSocketChannel> |
WebSocketClient.connect(XnioWorker worker,
ByteBufferPool bufferPool,
OptionMap optionMap,
URI uri,
WebSocketVersion version,
WebSocketClientNegotiation clientNegotiation)
Deprecated.
|
static IoFuture<WebSocketChannel> |
WebSocketClient.connect(XnioWorker worker,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap optionMap,
InetSocketAddress bindAddress,
URI uri,
WebSocketVersion version,
WebSocketClientNegotiation clientNegotiation,
Set<ExtensionHandshake> clientExtensions)
Deprecated.
|
static IoFuture<WebSocketChannel> |
WebSocketClient.connect(XnioWorker worker,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap optionMap,
URI uri,
WebSocketVersion version)
Deprecated.
|
static IoFuture<WebSocketChannel> |
WebSocketClient.connect(XnioWorker worker,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap optionMap,
URI uri,
WebSocketVersion version,
WebSocketClientNegotiation clientNegotiation)
Deprecated.
|
static IoFuture<WebSocketChannel> |
WebSocketClient.connect(XnioWorker worker,
XnioSsl ssl,
ByteBufferPool bufferPool,
OptionMap optionMap,
URI uri,
WebSocketVersion version,
WebSocketClientNegotiation clientNegotiation,
Set<ExtensionHandshake> clientExtensions)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected WebSocketChannel |
StreamSourceFrameChannel.getFramedChannel() |
WebSocketChannel |
StreamSourceFrameChannel.getWebSocketChannel() |
WebSocketChannel |
StreamSinkFrameChannel.getWebSocketChannel() |
Modifier and Type | Method and Description |
---|---|
Set<WebSocketChannel> |
WebSocketChannel.getPeerConnections()
Returns all 'peer' web socket connections that were created from the same endpoint.
|
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.onCloseMessage(CloseMessage cm,
WebSocketChannel channel) |
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,
long timeoutmillis)
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.sendBinary(ByteBuffer data,
WebSocketChannel wsChannel,
WebSocketCallback<Void> callback,
long timeoutmillis)
Sends a complete text message, invoking the callback when complete
|
static void |
WebSockets.sendBinaryBlocking(ByteBuffer[] data,
WebSocketChannel wsChannel)
Sends a complete binary message using blocking IO
|
static void |
WebSockets.sendBinaryBlocking(ByteBuffer data,
WebSocketChannel wsChannel)
Sends a complete binary message using blocking IO
|
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.sendClose(CloseMessage closeMessage,
WebSocketChannel wsChannel,
WebSocketCallback<Void> callback)
Sends a complete close message, invoking the callback when complete
|
static void |
WebSockets.sendClose(int code,
String reason,
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.sendCloseBlocking(CloseMessage closeMessage,
WebSocketChannel wsChannel)
Sends a complete close message, invoking the callback when complete
|
static void |
WebSockets.sendCloseBlocking(int code,
String reason,
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,
long timeoutmillis)
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.sendPing(ByteBuffer data,
WebSocketChannel wsChannel,
WebSocketCallback<Void> callback,
long timeoutmillis)
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,
long timeoutmillis)
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.sendPong(ByteBuffer data,
WebSocketChannel wsChannel,
WebSocketCallback<Void> callback,
long timeoutmillis)
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(ByteBuffer message,
WebSocketChannel wsChannel,
WebSocketCallback<Void> callback)
Sends a complete text message, invoking the callback when complete
|
static void |
WebSockets.sendText(ByteBuffer message,
WebSocketChannel wsChannel,
WebSocketCallback<Void> callback,
long timeoutmillis)
Sends a complete text message, invoking the callback when complete
|
static void |
WebSockets.sendText(String message,
WebSocketChannel wsChannel,
WebSocketCallback<Void> callback)
Sends a complete text message, invoking the callback when complete
|
static void |
WebSockets.sendText(String message,
WebSocketChannel wsChannel,
WebSocketCallback<Void> callback,
long timeoutmillis)
Sends a complete text message, invoking the callback when complete
|
static void |
WebSockets.sendTextBlocking(ByteBuffer message,
WebSocketChannel wsChannel)
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 |
---|
StreamSinkFrameChannel(WebSocketChannel channel,
WebSocketFrameType type) |
StreamSourceFrameChannel(WebSocketChannel wsChannel,
WebSocketFrameType type,
int rsv,
boolean finalFragment,
PooledByteBuffer pooled,
long frameLength,
Masker masker,
ChannelFunction... functions) |
StreamSourceFrameChannel(WebSocketChannel wsChannel,
WebSocketFrameType type,
PooledByteBuffer pooled,
long frameLength) |
Constructor and Description |
---|
WebSocketChannel(StreamConnection connectedStreamChannel,
ByteBufferPool bufferPool,
WebSocketVersion version,
String wsUrl,
String subProtocol,
boolean client,
boolean extensionsSupported,
ExtensionFunction extensionFunction,
Set<WebSocketChannel> peerConnections,
OptionMap options)
Create a new
WebSocketChannel
8 |
Modifier and Type | Method and Description |
---|---|
abstract WebSocketChannel |
Handshake.createChannel(WebSocketHttpExchange exchange,
StreamConnection channel,
ByteBufferPool pool)
Create the
WebSocketChannel from the WebSocketHttpExchange |
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,
StreamConnection channel,
ByteBufferPool pool) |
Constructor and Description |
---|
WebSocket07Channel(StreamConnection channel,
ByteBufferPool bufferPool,
String wsUrl,
String subProtocol,
boolean client,
boolean allowExtensions,
ExtensionFunction extensionFunction,
Set<WebSocketChannel> openConnections,
OptionMap options)
Create a new
WebSocket07Channel |
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,
StreamConnection channel,
ByteBufferPool pool) |
Constructor and Description |
---|
WebSocket08Channel(StreamConnection channel,
ByteBufferPool bufferPool,
String wsUrl,
String subProtocols,
boolean client,
boolean allowExtensions,
ExtensionFunction extensionFunction,
Set<WebSocketChannel> openConnections,
OptionMap options) |
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,
StreamConnection channel,
ByteBufferPool pool) |
Constructor and Description |
---|
WebSocket13Channel(StreamConnection channel,
ByteBufferPool bufferPool,
String wsUrl,
String subProtocols,
boolean client,
boolean allowExtensions,
ExtensionFunction extensionFunction,
Set<WebSocketChannel> openConnections,
OptionMap options) |
Modifier and Type | Method and Description |
---|---|
PooledByteBuffer |
PerMessageDeflateFunction.transformForRead(PooledByteBuffer pooledBuffer,
WebSocketChannel channel,
boolean lastFragmentOfFrame) |
PooledByteBuffer |
NoopExtensionFunction.transformForRead(PooledByteBuffer pooledBuffer,
WebSocketChannel channel,
boolean lastFragmentOfFrame) |
PooledByteBuffer |
ExtensionFunction.transformForRead(PooledByteBuffer pooledBuffer,
WebSocketChannel channel,
boolean lastFragmentOfFrame)
Transform the supplied buffer per this extension.
|
PooledByteBuffer |
CompositeExtensionFunction.transformForRead(PooledByteBuffer pooledBuffer,
WebSocketChannel channel,
boolean lastFragmentOfFrame) |
PooledByteBuffer |
PerMessageDeflateFunction.transformForWrite(PooledByteBuffer pooledBuffer,
WebSocketChannel channel) |
PooledByteBuffer |
NoopExtensionFunction.transformForWrite(PooledByteBuffer pooledBuffer,
WebSocketChannel channel) |
PooledByteBuffer |
ExtensionFunction.transformForWrite(PooledByteBuffer pooledBuffer,
WebSocketChannel channel)
Transform the supplied buffer per this extension.
|
PooledByteBuffer |
CompositeExtensionFunction.transformForWrite(PooledByteBuffer pooledBuffer,
WebSocketChannel channel) |
Modifier and Type | Method and Description |
---|---|
Set<WebSocketChannel> |
WebSocketHttpExchange.getPeerConnections() |
Set<WebSocketChannel> |
AsyncWebSocketHttpServerExchange.getPeerConnections() |
Constructor and Description |
---|
AsyncWebSocketHttpServerExchange(HttpServerExchange exchange,
Set<WebSocketChannel> peerConnections) |
BlockingWebSocketHttpServerExchange(HttpServerExchange exchange,
Set<WebSocketChannel> peerConnections) |
Copyright © 2016 JBoss by Red Hat. All rights reserved.