@ChannelHandler.Sharable
public class WebSocketServerHandler
extends io.netty.channel.SimpleChannelInboundHandler
Modifier and Type | Field and Description |
---|---|
static String |
SESSION_ATTR_WS_STATUS |
static String |
WEBSOCKET_ACTIVE |
static String |
WEBSOCKET_AWAIT_ACTIVATION |
static String |
WEBSOCKET_PATH |
Constructor and Description |
---|
WebSocketServerHandler(ErraiService bus) |
Modifier and Type | Method and Description |
---|---|
protected void |
channelRead0(io.netty.channel.ChannelHandlerContext ctx,
Object msg) |
void |
channelReadComplete(io.netty.channel.ChannelHandlerContext ctx) |
static void |
sendMessage(io.netty.channel.ChannelHandlerContext ctx,
String message) |
void |
stop() |
acceptInboundMessage, channelRead
channelActive, channelInactive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
handlerAdded, handlerRemoved, isSharable
public static final String SESSION_ATTR_WS_STATUS
public static final String WEBSOCKET_AWAIT_ACTIVATION
public static final String WEBSOCKET_ACTIVE
public static final String WEBSOCKET_PATH
public WebSocketServerHandler(ErraiService bus)
protected void channelRead0(io.netty.channel.ChannelHandlerContext ctx, Object msg) throws Exception
channelRead0
in class io.netty.channel.SimpleChannelInboundHandler
Exception
public void channelReadComplete(io.netty.channel.ChannelHandlerContext ctx) throws Exception
channelReadComplete
in interface io.netty.channel.ChannelInboundHandler
channelReadComplete
in class io.netty.channel.ChannelInboundHandlerAdapter
Exception
public static void sendMessage(io.netty.channel.ChannelHandlerContext ctx, String message)
public void stop()
Copyright © 2013-2015 JBoss, a division of Red Hat. All Rights Reserved.