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

    return createIdleStateHandler(r, w, 0L, unit);
  }
  
  public static IdleStateHandler createIdleStateHandler(
      long r, long w, long rw, TimeUnit unit) {
    return new IdleStateHandler(TIMER, r, w, rw, unit);
  }

View Full Code Here


    tcpServer = new ServerBootstrap(new NioServerSocketChannelFactory(
        Executors.newCachedThreadPool(), Executors.newCachedThreadPool()));
    tcpServer.setPipelineFactory(new ChannelPipelineFactory() {
      private final HashedWheelTimer timer = new HashedWheelTimer();
      private final IdleStateHandler idleStateHandler = new IdleStateHandler(
          timer, 0, 0, idleTimeMilliSeconds, TimeUnit.MILLISECONDS);


      @Override
      public ChannelPipeline getPipeline() throws Exception {
        return Channels.pipeline(RpcUtil.constructRpcFrameDecoder(),

View Full Code Here

                            readTimeout = clientAuth.getNetReadTimeout();
                        }
                        if (clientAuth.getNetWriteTimeout() > 0) {
                            writeTimeout = clientAuth.getNetWriteTimeout();
                        }
                        IdleStateHandler idleStateHandler = new IdleStateHandler(NettyUtils.hashedWheelTimer,
                                                                                 readTimeout, writeTimeout, 0);
                        ctx.getPipeline().addBefore(SessionHandler.class.getName(), IdleStateHandler.class.getName(),
                                                    idleStateHandler);


                        IdleStateAwareChannelHandler idleStateAwareChannelHandler = new IdleStateAwareChannelHandler() {

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(timer,
                                                                          (int) 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(),
                                                                          Ints.checkedCast(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("frameDecoder", new ThriftFrameDecoder(def.getMaxFrameSize(),
                                                                      def.getInProtocolFactory()));
                    if (def.getClientIdleTimeout() != null) {
                        // Add handlers to detect idle client connections and disconnect them
                        cp.addLast("idleTimeoutHandler", new IdleStateHandler(timer,
                                                                              (int)def.getClientIdleTimeout().toMillis(),
                                                                              NO_WRITER_IDLE_TIMEOUT,
                                                                              NO_ALL_IDLE_TIMEOUT,
                                                                              TimeUnit.MILLISECONDS
                                                                              ));

View Full Code Here

                            readTimeout = clientAuth.getNetReadTimeout();
                        }
                        if (clientAuth.getNetWriteTimeout() > 0) {
                            writeTimeout = clientAuth.getNetWriteTimeout();
                        }
                        IdleStateHandler idleStateHandler = new IdleStateHandler(NettyUtils.hashedWheelTimer,
                            readTimeout,
                            writeTimeout,
                            0);
                        ctx.getPipeline().addBefore(SessionHandler.class.getName(),
                            IdleStateHandler.class.getName(),

View Full Code Here

   * @see org.jboss.netty.channel.ChannelPipelineFactory#getPipeline()
   */
  public ChannelPipeline getPipeline() throws Exception {
    ChannelPipeline channelPipeline = Channels.pipeline();
    if (this.getIdleStateAwareChannelHandlerBean()!= null) {
      channelPipeline.addLast("idleStateCheck", new IdleStateHandler(timer, 0L, 0L, this.getChannelIdleTimeMillis(),TimeUnit.MILLISECONDS));
      channelPipeline.addLast("idleCheckHandler", (ChannelHandler)this.applicationContext.getBean(this.getIdleStateAwareChannelHandlerBean()));
    }
    for (String handlerKey : this.getChannelHandlerBeanNamesMap().keySet()) {
      channelPipeline.addLast(handlerKey, (ChannelHandler)this.applicationContext.getBean(this.getChannelHandlerBeanNamesMap().get(handlerKey)));
    }

View Full Code Here

                cp.addLast(ChannelStatistics.NAME, channelStatistics);
                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

            private final TimeUnit TIMEOUT_UNIT = TimeUnit.SECONDS;


            public ChannelPipeline getPipeline() throws Exception {
                ChannelPipeline pipeline = pipeline();
                pipeline.addLast(GROUP_HANDLER, groupHandler);
                pipeline.addLast("idleHandler", new IdleStateHandler(timer, 0, 0, timeout, TIMEOUT_UNIT));
                pipeline.addLast(TIMEOUT_HANDLER, new ImapIdleStateHandler());
                pipeline.addLast(CONNECTION_LIMIT_HANDLER, new ConnectionLimitUpstreamHandler(IMAPServer.this.connectionLimit));


                pipeline.addLast(CONNECTION_LIMIT_PER_IP_HANDLER, new ConnectionPerIpLimitUpstreamHandler(IMAPServer.this.connPerIP));

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.