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 class: ChannelInterceptorBase
        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 - int value of
        DEFAULT - will start all services
        MBR_RX_SEQ - starts the membership receiver
        MBR_TX_SEQ - starts the membership broadcaster
        SND_TX_SEQ - starts the replication transmitter
        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 class: ChannelInterceptorBase
        Shuts down the channel. This can be called multiple times for individual services to shutdown 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 - int value of
        DEFAULT - will shutdown all services
        MBR_RX_SEQ - stops the membership receiver
        MBR_TX_SEQ - stops the membership broadcaster
        SND_TX_SEQ - stops the replication transmitter
        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)