Package org.jboss.netty.example.factorial

Class FactorialClientHandler

java.lang.Object

org.jboss.netty.channel.SimpleChannelUpstreamHandler

org.jboss.netty.example.factorial.FactorialClientHandler

All Implemented Interfaces:

ChannelHandler, ChannelUpstreamHandler

public class FactorialClientHandler
extends SimpleChannelUpstreamHandler

Handler for a client-side channel. This handler maintains stateful information which is specific to a certain channel using member variables. Therefore, an instance of this handler can cover only one channel. You have to create a new handler instance whenever you create a new channel and insert this handler to avoid a race condition.

Nested Class Summary

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

ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final BlockingQueue<BigInteger>	answer
private int	i
private int	receivedMessages

Constructor Summary

Constructors

Constructor	Description
FactorialClientHandler()

Method Summary

Modifier and Type	Method	Description
void	channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e)	Invoked when a Channel is open, bound to a local address, and connected to a remote address.
void	channelInterestChanged(ChannelHandlerContext ctx, ChannelStateEvent e)	Invoked when a Channel's interestOps was changed.
void	exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e)	Invoked when an exception was raised by an I/O thread or a ChannelHandler.
BigInteger	getFactorial()
void	handleUpstream(ChannelHandlerContext ctx, ChannelEvent e)	Handles the specified upstream event.
void	messageReceived(ChannelHandlerContext ctx, MessageEvent e)	Invoked when a message object (e.g: ChannelBuffer) was received from a remote peer.
private void	sendNumbers(ChannelStateEvent e)

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

channelBound, channelClosed, channelDisconnected, channelOpen, channelUnbound, childChannelClosed, childChannelOpen, writeComplete

Methods inherited from class java.lang.Object

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

Field Details

i

private int i

receivedMessages

private int receivedMessages

answer

final BlockingQueue<BigInteger> answer

Constructor Details

FactorialClientHandler

public FactorialClientHandler()

Method Details

getFactorial

public BigInteger getFactorial()

handleUpstream

public void handleUpstream(ChannelHandlerContext ctx,
 ChannelEvent e)
                    throws Exception

Description copied from class: SimpleChannelUpstreamHandler

Handles the specified upstream event. Down-casts the received upstream event into more meaningful sub-type event and calls an appropriate handler method with the down-casted event.

Specified by:

handleUpstream in interface ChannelUpstreamHandler

Overrides:

handleUpstream in class SimpleChannelUpstreamHandler

Parameters:

ctx - the context object for this handler

e - the upstream event to process or intercept

Throws:

Exception

channelConnected

public void channelConnected(ChannelHandlerContext ctx,
 ChannelStateEvent e)

Description copied from class: SimpleChannelUpstreamHandler

Invoked when a Channel is open, bound to a local address, and connected to a remote address.
Be aware that this event is fired from within the I/O thread. You should never execute any heavy operation in there as it will block the dispatching to other workers!

Overrides:

channelConnected in class SimpleChannelUpstreamHandler

channelInterestChanged

public void channelInterestChanged(ChannelHandlerContext ctx,
 ChannelStateEvent e)

Description copied from class: SimpleChannelUpstreamHandler

Invoked when a Channel's interestOps was changed.

Overrides:

channelInterestChanged in class SimpleChannelUpstreamHandler

messageReceived

public void messageReceived(ChannelHandlerContext ctx,
 MessageEvent e)

Description copied from class: SimpleChannelUpstreamHandler

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

Overrides:

messageReceived in class SimpleChannelUpstreamHandler

exceptionCaught

public void exceptionCaught(ChannelHandlerContext ctx,
 ExceptionEvent e)

Description copied from class: SimpleChannelUpstreamHandler

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

Overrides:

exceptionCaught in class SimpleChannelUpstreamHandler

sendNumbers

private void sendNumbers(ChannelStateEvent e)