org.jooby.internal.netty

Class NettyWebSocket

java.lang.Object

org.jooby.internal.netty.NettyWebSocket

All Implemented Interfaces:

NativeWebSocket

public class NettyWebSocket
extends Object
implements NativeWebSocket

Field Summary

Fields

Modifier and Type	Field and Description
static io.netty.util.AttributeKey<NettyWebSocket>	KEY

Constructor Summary

Constructors

Constructor and Description
NettyWebSocket(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.websocketx.WebSocketServerHandshaker handshaker, Consumer<NettyWebSocket> handshake)

Method Summary

Modifier and Type	Method and Description
void	close(int status, String reason)
void	connect()
void	handle(Object msg)
void	hankshake()
boolean	isOpen()
void	onBinaryMessage(Consumer<ByteBuffer> callback)
void	onCloseMessage(BiConsumer<Integer,Optional<String>> callback)
void	onConnect(Runnable callback)
void	onErrorMessage(Consumer<Throwable> callback)
void	onTextMessage(Consumer<String> callback)
void	pause()
void	resume()
void	sendBytes(byte[] data, WebSocket.SuccessCallback success, WebSocket.ErrCallback err)
void	sendBytes(ByteBuffer data, WebSocket.SuccessCallback success, WebSocket.ErrCallback err)
void	sendText(byte[] data, WebSocket.SuccessCallback success, WebSocket.ErrCallback err)
void	sendText(ByteBuffer data, WebSocket.SuccessCallback success, WebSocket.ErrCallback err)
void	sendText(String data, WebSocket.SuccessCallback success, WebSocket.ErrCallback err)
void	terminate()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

KEY

public static final io.netty.util.AttributeKey<NettyWebSocket> KEY

Constructor Detail

NettyWebSocket

public NettyWebSocket(io.netty.channel.ChannelHandlerContext ctx,
                      io.netty.handler.codec.http.websocketx.WebSocketServerHandshaker handshaker,
                      Consumer<NettyWebSocket> handshake)

Method Detail

close

public void close(int status,
                  String reason)

Specified by:

close in interface NativeWebSocket

resume

public void resume()

Specified by:

resume in interface NativeWebSocket

onConnect

public void onConnect(Runnable callback)

Specified by:

onConnect in interface NativeWebSocket

onTextMessage

public void onTextMessage(Consumer<String> callback)

Specified by:

onTextMessage in interface NativeWebSocket

onBinaryMessage

public void onBinaryMessage(Consumer<ByteBuffer> callback)

Specified by:

onBinaryMessage in interface NativeWebSocket

onCloseMessage

public void onCloseMessage(BiConsumer<Integer,Optional<String>> callback)

Specified by:

onCloseMessage in interface NativeWebSocket

onErrorMessage

public void onErrorMessage(Consumer<Throwable> callback)

Specified by:

onErrorMessage in interface NativeWebSocket

pause

public void pause()

Specified by:

pause in interface NativeWebSocket

terminate

public void terminate()
               throws IOException

Specified by:

terminate in interface NativeWebSocket

Throws:

IOException

sendBytes

public void sendBytes(ByteBuffer data,
                      WebSocket.SuccessCallback success,
                      WebSocket.ErrCallback err)

Specified by:

sendBytes in interface NativeWebSocket

sendBytes

public void sendBytes(byte[] data,
                      WebSocket.SuccessCallback success,
                      WebSocket.ErrCallback err)

Specified by:

sendBytes in interface NativeWebSocket

sendText

public void sendText(String data,
                     WebSocket.SuccessCallback success,
                     WebSocket.ErrCallback err)

Specified by:

sendText in interface NativeWebSocket

sendText

public void sendText(ByteBuffer data,
                     WebSocket.SuccessCallback success,
                     WebSocket.ErrCallback err)

Specified by:

sendText in interface NativeWebSocket

sendText

public void sendText(byte[] data,
                     WebSocket.SuccessCallback success,
                     WebSocket.ErrCallback err)

Specified by:

sendText in interface NativeWebSocket

isOpen

public boolean isOpen()

Specified by:

isOpen in interface NativeWebSocket

connect

public void connect()

hankshake

public void hankshake()

handle

public void handle(Object msg)