andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Simplfied the factorial example using the new SimpleChannelHandler

Browse Source
This commit is contained in:
Trustin Lee 2008-10-02 04:44:06 +00:00
parent ca1f11ff67
commit 5120c1172c
1 changed files with 6 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/main/java/org/jboss/netty/example/factorial/NumberEncoder.java
View File

@ -28,11 +28,10 @@ import java.math.BigInteger;
import org.jboss.netty.buffer.ChannelBuffer;
import org.jboss.netty.buffer.ChannelBuffers;
import org.jboss.netty.channel.ChannelDownstreamHandler;
import org.jboss.netty.channel.ChannelEvent;
import org.jboss.netty.channel.ChannelHandlerContext;
import org.jboss.netty.channel.ChannelPipelineCoverage;
import org.jboss.netty.channel.MessageEvent;
import org.jboss.netty.channel.SimpleChannelHandler;
/**
* Encodes a {@link Number} into the binary representation with a 32-bit length
@ -45,19 +44,14 @@ import org.jboss.netty.channel.MessageEvent;
*
*/
@ChannelPipelineCoverage("all")
public class NumberEncoder implements ChannelDownstreamHandler {
public class NumberEncoder extends SimpleChannelHandler {
public void handleDownstream(
ChannelHandlerContext ctx, ChannelEvent evt) throws Exception {
if (!(evt instanceof MessageEvent)) {
ctx.sendDownstream(evt);
return;
}
MessageEvent e = (MessageEvent) evt;
@Override
public void writeRequested(
ChannelHandlerContext ctx, MessageEvent e) throws Exception {
if (!(e.getMessage() instanceof Number)) {
// Ignore what this encoder can't encode.
ctx.sendDownstream(evt);
ctx.sendDownstream(e);
return;
}