Class TcpPingInterceptor

    • Field Detail

      • TCP_PING_DATA

        protected static final byte[] TCP_PING_DATA
      • interval

        protected long interval
      • useThread

        protected boolean useThread
      • staticOnly

        protected boolean staticOnly
      • running

        protected volatile boolean running
      • cnt

        protected static final java.util.concurrent.atomic.AtomicInteger cnt
    • Constructor Detail

      • TcpPingInterceptor

        public TcpPingInterceptor()
    • Method Detail

      • start

        public void start​(int svc)
                   throws ChannelException
        Description copied from interface: ChannelInterceptor
        Starts up the channel. This can be called multiple times for individual services to start The svc parameter can be the logical or value of any constants
        Specified by:
        start in interface ChannelInterceptor
        Overrides:
        start in class ChannelInterceptorBase
        Parameters:
        svc - one of:
        • Channel.DEFAULT - will start all services
        • Channel.MBR_RX_SEQ - starts the membership receiver
        • Channel.MBR_TX_SEQ - starts the membership broadcaster
        • Channel.SND_TX_SEQ - starts the replication transmitter
        • Channel.SND_RX_SEQ - starts the replication receiver
        Throws:
        ChannelException - if a startup error occurs or the service is already started.
        See Also:
        Channel
      • stop

        public void stop​(int svc)
                  throws ChannelException
        Description copied from interface: ChannelInterceptor
        Shuts down the channel. This can be called multiple times for individual services to shut down. The svc parameter can be the logical or value of any constants
        Specified by:
        stop in interface ChannelInterceptor
        Overrides:
        stop in class ChannelInterceptorBase
        Parameters:
        svc - one of:
        • Channel.DEFAULT - will shut down all services
        • Channel.MBR_RX_SEQ - stops the membership receiver
        • Channel.MBR_TX_SEQ - stops the membership broadcaster
        • Channel.SND_TX_SEQ - stops the replication transmitter
        • Channel.SND_RX_SEQ - stops the replication receiver
        Throws:
        ChannelException - if a startup error occurs or the service is already started.
        See Also:
        Channel
      • setInterval

        public void setInterval​(long interval)
      • setUseThread

        public void setUseThread​(boolean useThread)
      • setStaticOnly

        public void setStaticOnly​(boolean staticOnly)
      • getStaticOnly

        public boolean getStaticOnly()
      • sendPing

        protected void sendPing()
      • sendPingMessage

        protected void sendPingMessage​(Member[] members)