From cac77a47b265e4fd2e39fc469d0abb6d32704b72 Mon Sep 17 00:00:00 2001 From: Trustin Lee Date: Tue, 6 Apr 2010 09:40:35 +0000 Subject: [PATCH] Fixed a wrong usage of ExecutionHandler in the example --- .../netty/example/local/LocalServerPipelineFactory.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/org/jboss/netty/example/local/LocalServerPipelineFactory.java b/src/main/java/org/jboss/netty/example/local/LocalServerPipelineFactory.java index d3898843d1..9778024f0c 100644 --- a/src/main/java/org/jboss/netty/example/local/LocalServerPipelineFactory.java +++ b/src/main/java/org/jboss/netty/example/local/LocalServerPipelineFactory.java @@ -37,17 +37,17 @@ import org.jboss.netty.handler.execution.ExecutionHandler; */ public class LocalServerPipelineFactory implements ChannelPipelineFactory { - private final Executor eventExecutor; + private final ExecutionHandler executionHandler; public LocalServerPipelineFactory(Executor eventExecutor) { - this.eventExecutor = eventExecutor; + executionHandler = new ExecutionHandler(eventExecutor); } public ChannelPipeline getPipeline() throws Exception { final ChannelPipeline pipeline = Channels.pipeline(); pipeline.addLast("decoder", new StringDecoder()); pipeline.addLast("encoder", new StringEncoder()); - pipeline.addLast("executor", new ExecutionHandler(eventExecutor)); + pipeline.addLast("executor", executionHandler); pipeline.addLast("handler", new EchoCloseServerHandler()); return pipeline; }