Hi Benoit,<br><br>Thank you for your response. Now I'm able to understand how to use ExecutionHandler in ChannelPipelineFactory. However, I have another question regarding pipeline. My server should receive byte array with length field from remote client. In here I would expect to use LengthFieldBasedFrameDecoder. However, from the next handler byte array should be parsed and values should used to construct user defined java object. We have encode/decode method that constructs byte array from Java object (not serialization) and vise versa. Since, I'm new to Netty, I'm confused. Anybody could give some hint how pipeline interception filter should be used? Should I use those custom encode/decode methods as a custom decoder/encoder? If then how that java object would be passed to next business logic handler? Thank you.<br>
<br> ChannelPipeline p = Channels.pipeline();<br> p.addLast("framer", new LengthFieldBasedFrameDecoder(...));<br> ......<br> .....?<br> .....<br> p.addLast("businessLogic", new MyCustomHandler(...));<br>
<br>Albert<br><br><div class="gmail_quote">On Fri, May 13, 2011 at 1:34 AM, Benoit Perroud <span dir="ltr"><<a href="mailto:benoit@noisette.ch">benoit@noisette.ch</a>></span> wrote:<br><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex;">
To handle heavy tasks (take long time to execute) you should add an<br>
ExecutionHandler in the pipeline. This will free the I/O workers and<br>
you will have a dedicated ThreadPool that you can fine tune to execute<br>
your heavy tasks, just like in SEDA<br>
(<a href="http://en.wikipedia.org/wiki/Staged_event-driven_architecture" target="_blank">http://en.wikipedia.org/wiki/Staged_event-driven_architecture</a>)<br>
<br>
<br>
<br>
2011/5/13 Albert Nikola <<a href="mailto:albert.nikola@gmail.com">albert.nikola@gmail.com</a>>:<br>
<div><div></div><div class="h5">> Hi All,<br>
><br>
> I'm fairly new to Java and my research led me to Netty. I read that Netty<br>
> uses same design pattern with MINA and xSocket. Does this mean the Netty is<br>
> complete reactor pattern NIO framework and is concurrency and<br>
> synchronization issue in threading already taken care of? I'm wondering that<br>
> if the task to process message is heavy then how should I handle this?<br>
> Please help me to get enlightened. Thanks.<br>
><br>
> Albert<br>
><br>
</div></div>> _______________________________________________<br>
> netty-users mailing list<br>
> <a href="mailto:netty-users@lists.jboss.org">netty-users@lists.jboss.org</a><br>
> <a href="https://lists.jboss.org/mailman/listinfo/netty-users" target="_blank">https://lists.jboss.org/mailman/listinfo/netty-users</a><br>
><br>
_______________________________________________<br>
netty-users mailing list<br>
<a href="mailto:netty-users@lists.jboss.org">netty-users@lists.jboss.org</a><br>
<a href="https://lists.jboss.org/mailman/listinfo/netty-users" target="_blank">https://lists.jboss.org/mailman/listinfo/netty-users</a><br>
</blockquote></div><br>