Right way to shutdown in case of error
Michael McGrady
mmcgrady at topiatechnology.com
Tue Sep 15 12:29:53 EDT 2009
Oops. Sorry. I will look at it.
Mike
On Sep 15, 2009, at 12:19 AM, float_dublin wrote:
>
> It is fully included in messages i post.
>
>
> Mike McGrady wrote:
>>
>> Could you give the relevant code? I suspect that you are not getting
>> all channels into the group.
>>
>> Mike
>>
>> On Sep 14, 2009, at 4:12 AM, float_dublin wrote:
>>
>>>
>>> OK, I am using ChannelGroups this time still with no success. No
>>> channel gets
>>> into Channelgroup in case of "Connection refused". Examining
>>> ClientBootstrap
>>> gives no clue :( Application still hangs. So is a new thread for
>>> shuting
>>> down the only solution?
>>>
>>> Code:
>>> public class ClientTest {
>>>
>>> @ChannelPipelineCoverage("all")
>>> private class Client extends SimpleChannelHandler {
>>>
>>> @Override
>>> public void channelOpen(ChannelHandlerContext ctx,
>>> ChannelStateEvent
>>> e) throws Exception {
>>> group.add(e.getChannel());
>>> }
>>>
>>> @Override
>>> public void exceptionCaught(ChannelHandlerContext ctx, final
>>> ExceptionEvent e) throws Exception {
>>> e.getCause().printStackTrace();
>>> System.out.println("Channels in group: " + group.size());
>>> group.close().addListener(new
>>> ChannelGroupFutureListener() {
>>>
>>> public void operationComplete(ChannelGroupFuture
>>> future)
>>> throws Exception {
>>> bootstrap.releaseExternalResources();
>>> }
>>> });
>>> }
>>> }
>>> final ClientBootstrap bootstrap = new ClientBootstrap(new
>>> NioClientSocketChannelFactory(
>>> Executors.newCachedThreadPool(),
>>> Executors.newCachedThreadPool()));
>>> final ChannelGroup group = new DefaultChannelGroup();
>>>
>>> private void initClient() {
>>> bootstrap.setOption("tcpNoDelay", true);
>>> bootstrap.setOption("keepAlive", true);
>>>
>>> final ChannelPipeline pipeline = bootstrap.getPipeline();
>>> pipeline.addLast("handler", new Client());
>>> group.add(bootstrap.connect(new InetSocketAddress("localhost",
>>> 20001)).getChannel());
>>> }
>>>
>>> public static void main(String[] args) {
>>> new ClientTest().initClient();
>>> }
>>> }
>>> --
>>> View this message in context:
>>> http://n2.nabble.com/Right-way-to-shutdown-in-case-of-error-tp3637599p3641407.html
>>> Sent from the Netty User Group mailing list archive at Nabble.com.
>>> _______________________________________________
>>> netty-users mailing list
>>> netty-users at lists.jboss.org
>>> https://lists.jboss.org/mailman/listinfo/netty-users
>>
>> Mike McGrady
>> Principal Investigator AF081-028 AFRL SBIR
>> Senior Engineer
>> Topia Technology, Inc
>> 1.253.720.3365
>> mmcgrady at topiatechnology.com
>>
>>
>>
>>
>>
>>
>>
>> _______________________________________________
>> netty-users mailing list
>> netty-users at lists.jboss.org
>> https://lists.jboss.org/mailman/listinfo/netty-users
>>
>>
>
> --
> View this message in context: http://n2.nabble.com/Right-way-to-shutdown-in-case-of-error-tp3637599p3647296.html
> Sent from the Netty User Group mailing list archive at Nabble.com.
> _______________________________________________
> netty-users mailing list
> netty-users at lists.jboss.org
> https://lists.jboss.org/mailman/listinfo/netty-users
Mike McGrady
Principal Investigator AF081-028 AFRL SBIR
Senior Engineer
Topia Technology, Inc
1.253.720.3365
mmcgrady at topiatechnology.com
More information about the netty-users
mailing list