Package org.jboss.netty.handler.codec.http.websocketx

Class WebSocketServerProtocolHandler

java.lang.Object

org.jboss.netty.channel.SimpleChannelUpstreamHandler

org.jboss.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler

All Implemented Interfaces:

ChannelHandler, ChannelUpstreamHandler, LifeCycleAwareChannelHandler

public class WebSocketServerProtocolHandler
extends SimpleChannelUpstreamHandler
implements LifeCycleAwareChannelHandler

Handles WebSocket control frames (Close, Ping, Pong) and data frames (Text and Binary) are passed to the next handler in the pipeline.

Nested Class Summary

Nested classes/interfaces inherited from interface org.jboss.netty.channel.ChannelHandler

ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field	Description
private final boolean	allowExtensions
private final String	subprotocols
private final String	websocketPath

Constructor Summary

Constructors

Constructor	Description
WebSocketServerProtocolHandler(String websocketPath)
WebSocketServerProtocolHandler(String websocketPath, String subprotocols)
WebSocketServerProtocolHandler(String websocketPath, String subprotocols, boolean allowExtensions)

Method Summary

Modifier and Type	Method	Description
void	afterAdd(ChannelHandlerContext ctx)
void	afterRemove(ChannelHandlerContext ctx)
void	beforeAdd(ChannelHandlerContext ctx)
void	beforeRemove(ChannelHandlerContext ctx)
void	exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e)	Invoked when an exception was raised by an I/O thread or a ChannelHandler.
(package private) static ChannelHandler	forbiddenHttpRequestResponder()
(package private) static WebSocketServerHandshaker	getHandshaker(ChannelHandlerContext ctx)
void	messageReceived(ChannelHandlerContext ctx, MessageEvent e)	Invoked when a message object (e.g: ChannelBuffer) was received from a remote peer.
(package private) static void	setHandshaker(ChannelHandlerContext ctx, WebSocketServerHandshaker handshaker)

Methods inherited from class org.jboss.netty.channel.SimpleChannelUpstreamHandler

channelBound, channelClosed, channelConnected, channelDisconnected, channelInterestChanged, channelOpen, channelUnbound, childChannelClosed, childChannelOpen, handleUpstream, writeComplete

Methods inherited from class java.lang.Object

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

Field Details

websocketPath

private final String websocketPath

subprotocols

private final String subprotocols

allowExtensions

private final boolean allowExtensions

Constructor Details

WebSocketServerProtocolHandler

public WebSocketServerProtocolHandler(String websocketPath)

WebSocketServerProtocolHandler

public WebSocketServerProtocolHandler(String websocketPath,
 String subprotocols)

WebSocketServerProtocolHandler

public WebSocketServerProtocolHandler(String websocketPath,
 String subprotocols,
 boolean allowExtensions)

Method Details

afterAdd

public void afterAdd(ChannelHandlerContext ctx)
              throws Exception

Specified by:

afterAdd in interface LifeCycleAwareChannelHandler

Throws:

Exception

messageReceived

public void messageReceived(ChannelHandlerContext ctx,
 MessageEvent e)
                     throws Exception

Description copied from class: SimpleChannelUpstreamHandler

Invoked when a message object (e.g: ChannelBuffer) was received from a remote peer.

Overrides:

messageReceived in class SimpleChannelUpstreamHandler

Throws:

Exception

exceptionCaught

public void exceptionCaught(ChannelHandlerContext ctx,
 ExceptionEvent e)
                     throws Exception

Description copied from class: SimpleChannelUpstreamHandler

Invoked when an exception was raised by an I/O thread or a ChannelHandler.

Overrides:

exceptionCaught in class SimpleChannelUpstreamHandler

Throws:

Exception

getHandshaker

static WebSocketServerHandshaker getHandshaker(ChannelHandlerContext ctx)

setHandshaker

static void setHandshaker(ChannelHandlerContext ctx,
 WebSocketServerHandshaker handshaker)

forbiddenHttpRequestResponder

static ChannelHandler forbiddenHttpRequestResponder()

beforeAdd

public void beforeAdd(ChannelHandlerContext ctx)
               throws Exception

Specified by:

beforeAdd in interface LifeCycleAwareChannelHandler

Throws:

Exception

beforeRemove

public void beforeRemove(ChannelHandlerContext ctx)
                  throws Exception

Specified by:

beforeRemove in interface LifeCycleAwareChannelHandler

Throws:

Exception

afterRemove

public void afterRemove(ChannelHandlerContext ctx)
                 throws Exception

Specified by:

afterRemove in interface LifeCycleAwareChannelHandler

Throws:

Exception