org.xbib.elasticsearch.http.netty.client

Class NettyWebSocketClientHandler

java.lang.Object

org.jboss.netty.channel.SimpleChannelUpstreamHandler

org.xbib.elasticsearch.http.netty.client.NettyWebSocketClientHandler

All Implemented Interfaces:

org.jboss.netty.channel.ChannelHandler, org.jboss.netty.channel.ChannelUpstreamHandler, WebSocketClient

public class NettyWebSocketClientHandler
extends org.jboss.netty.channel.SimpleChannelUpstreamHandler
implements WebSocketClient

Handles socket communication for a connected WebSocket client. Not intended for end-users. Please use NettyWebSocketClient for controlling your client.

Nested Class Summary

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

org.jboss.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
NettyWebSocketClientHandler(org.jboss.netty.bootstrap.ClientBootstrap bootstrap, URI url, WebSocketActionListener listener)

Method Summary

Methods

Modifier and Type	Method and Description
org.jboss.netty.channel.Channel	channel() The channel this client has opened.
void	channelClosed(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent event)
void	channelConnected(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent event)
org.jboss.netty.channel.ChannelFuture	connect() Connect to host and port.
org.jboss.netty.channel.ChannelFuture	disconnect() Disconnect from the server
void	exceptionCaught(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ExceptionEvent e)
void	messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.MessageEvent event)
org.jboss.netty.channel.ChannelFuture	send(org.jboss.netty.handler.codec.http.websocketx.WebSocketFrame frame) Send data to server

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

channelBound, 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

Constructor Detail

NettyWebSocketClientHandler

public NettyWebSocketClientHandler(org.jboss.netty.bootstrap.ClientBootstrap bootstrap,
                           URI url,
                           WebSocketActionListener listener)

Method Detail

channel

public org.jboss.netty.channel.Channel channel()

Description copied from interface: WebSocketClient

The channel this client has opened.

Specified by:

channel in interface WebSocketClient

Returns:

the channel

channelConnected

public void channelConnected(org.jboss.netty.channel.ChannelHandlerContext ctx,
                    org.jboss.netty.channel.ChannelStateEvent event)
                      throws Exception

Overrides:

channelConnected in class org.jboss.netty.channel.SimpleChannelUpstreamHandler

Throws:

Exception

channelClosed

public void channelClosed(org.jboss.netty.channel.ChannelHandlerContext ctx,
                 org.jboss.netty.channel.ChannelStateEvent event)
                   throws Exception

Overrides:

channelClosed in class org.jboss.netty.channel.SimpleChannelUpstreamHandler

Throws:

Exception

messageReceived

public void messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx,
                   org.jboss.netty.channel.MessageEvent event)
                     throws Exception

Overrides:

messageReceived in class org.jboss.netty.channel.SimpleChannelUpstreamHandler

Throws:

Exception

exceptionCaught

public void exceptionCaught(org.jboss.netty.channel.ChannelHandlerContext ctx,
                   org.jboss.netty.channel.ExceptionEvent e)
                     throws Exception

Overrides:

exceptionCaught in class org.jboss.netty.channel.SimpleChannelUpstreamHandler

Throws:

Exception

connect

public org.jboss.netty.channel.ChannelFuture connect()

Description copied from interface: WebSocketClient

Connect to host and port.

Specified by:

connect in interface WebSocketClient

Returns:

Connect future. Fires when connected.

disconnect

public org.jboss.netty.channel.ChannelFuture disconnect()

Description copied from interface: WebSocketClient

Disconnect from the server

Specified by:

disconnect in interface WebSocketClient

Returns:

Disconnect future. Fires when disconnected.

send

public org.jboss.netty.channel.ChannelFuture send(org.jboss.netty.handler.codec.http.websocketx.WebSocketFrame frame)

Description copied from interface: WebSocketClient

Send data to server

Specified by:

send in interface WebSocketClient

Parameters:

frame - Data for sending

Returns:

Write future. Will fire when the data is sent.