Examples of org.jboss.netty.handler.timeout.IdleStateHandler

org.jboss.netty.handler.timeout.IdleStateHandler
xample that sends a ping message when there is no outbound traffic // for 30 seconds. The connection is closed when there is no inbound traffic // for 60 seconds. public class MyPipelineFactory implements {@link ChannelPipelineFactory} {private final {@link Timer} timer;public MyPipelineFactory( {@link Timer} timer) {this.timer = timer; } public {@link ChannelPipeline} getPipeline() {return {@link Channels}.pipeline( new {@link IdleStateHandler}(timer, 60, 30, 0), // timer must be shared. new MyHandler()); } } // Handler should handle the {@link IdleStateEvent} triggered by {@link IdleStateHandler}. public class MyHandler extends {@link IdleStateAwareChannelHandler} {{@code @Override}public void channelIdle( {@link ChannelHandlerContext} ctx, {@link IdleStateEvent} e) {if (e.getState() == {@link IdleState}.READER_IDLE) { e.getChannel().close(); } else if (e.getState() == {@link IdleState}.WRITER_IDLE) { e.getChannel().write(new PingMessage()); } } } {@link ServerBootstrap} bootstrap = ...;{@link Timer} timer = new {@link HashedWheelTimer}(); ... bootstrap.setPipelineFactory(new MyPipelineFactory(timer)); ... The {@link Timer} which was specified when the {@link ReadTimeoutHandler} iscreated should be stopped manually by calling {@link #releaseExternalResources()}or {@link Timer#stop()} when your application shuts down. @author The Netty Project @author Trustin Lee @version $Rev: 2224 $, $Date: 2010-03-30 17:02:32 +0900 (Tue, 30 Mar 2010) $ @see ReadTimeoutHandler @see WriteTimeoutHandler @apiviz.landmark @apiviz.uses org.jboss.netty.util.HashedWheelTimer @apiviz.has org.jboss.netty.handler.timeout.IdleStateEvent oneway - - triggers


    @Override
    public ChannelPipeline getPipeline() {
        ChannelPipeline pipeline = Channels.pipeline();
        if (resetDelay != null) {
            pipeline.addLast("idleHandler", new IdleStateHandler(GlobalTimer.getTimer(), resetDelay, 0, 0));
        }
        pipeline.addLast("openHandler", new OpenChannelHandler(server));
        if (loggerEnabled) {
            pipeline.addLast("logger", new StandardLoggingHandler());
        }

View Full Code Here

                cp.addLast("encryptionHandler", securityHandlers.getEncryptionHandler());
                cp.addLast("frameCodec", def.getThriftFrameCodecFactory().create(def.getMaxFrameSize(),
                                                                                 inputProtocolFactory));
                if (def.getClientIdleTimeout() != null) {
                    // Add handlers to detect idle client connections and disconnect them
                    cp.addLast("idleTimeoutHandler", new IdleStateHandler(nettyServerConfig.getTimer(),
                                                                          def.getClientIdleTimeout().toMillis(),
                                                                          NO_WRITER_IDLE_TIMEOUT,
                                                                          NO_ALL_IDLE_TIMEOUT,
                                                                          TimeUnit.MILLISECONDS));
                    cp.addLast("idleDisconnectHandler", new IdleDisconnectHandler());

View Full Code Here

                cp.addLast("encryptionHandler", securityHandlers.getEncryptionHandler());
                cp.addLast("frameCodec", def.getThriftFrameCodecFactory().create(def.getMaxFrameSize(),
                                                                                 inputProtocolFactory));
                if (def.getClientIdleTimeout() != null) {
                    // Add handlers to detect idle client connections and disconnect them
                    cp.addLast("idleTimeoutHandler", new IdleStateHandler(nettyServerConfig.getTimer(),
                                                                          def.getClientIdleTimeout().toMillis(),
                                                                          NO_WRITER_IDLE_TIMEOUT,
                                                                          NO_ALL_IDLE_TIMEOUT,
                                                                          TimeUnit.MILLISECONDS));
                    cp.addLast("idleDisconnectHandler", new IdleDisconnectHandler());

View Full Code Here

                cp.addLast(ChannelStatistics.NAME, new ChannelStatistics(allChannels));
                cp.addLast("frameCodec", def.getThriftFrameCodecFactory().create(def.getMaxFrameSize(),
                                                                                 inputProtocolFactory));
                if (def.getClientIdleTimeout() != null) {
                    // Add handlers to detect idle client connections and disconnect them
                    cp.addLast("idleTimeoutHandler", new IdleStateHandler(nettyServerConfig.getTimer(),
                                                                          def.getClientIdleTimeout().toMillis(),
                                                                          NO_WRITER_IDLE_TIMEOUT,
                                                                          NO_ALL_IDLE_TIMEOUT,
                                                                          TimeUnit.MILLISECONDS));
                    cp.addLast("idleDisconnectHandler", new IdleDisconnectHandler());

View Full Code Here

0 1 2

TOP

Related Classes of org.jboss.netty.handler.timeout.IdleStateHandler

com.alibaba.otter.canal.server.netty.handler.ClientAuthenticationHandler

com.facebook.nifty.core.NettyServerTransport

com.flipkart.phantom.runtime.impl.server.netty.ChannelHandlerPipelineFactory

com.llfix.FIXAcceptorPipelineFactory

com.llfix.FIXInitiatorPipelineFactory

com.nabalive.framework.web.HttpApiServerPipelineFactory

com.nabalive.server.jabber.NabaliveServer

net.floodlightcontroller.core.internal.OpenflowPipelineFactory

org.apache.hadoop.portmap.Portmap

org.apache.james.imapserver.netty.IMAPServer

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.