Class ReconnectRequest

java.lang.Object
net.rubyeye.xmemcached.impl.ReconnectRequest
All Implemented Interfaces:
Comparable<Delayed>, Delayed

public final class ReconnectRequest extends Object implements Delayed
A auto reconnect request,associating a socket address for reconnecting
  • Field Details

    • inetSocketAddressWrapper

      private InetSocketAddressWrapper inetSocketAddressWrapper
    • tries

      private int tries
    • MIN_RECONNECT_INTERVAL

      private static final long MIN_RECONNECT_INTERVAL
      See Also:
    • MAX_RECONNECT_INTERVAL

      private static final long MAX_RECONNECT_INTERVAL
      See Also:
    • nextReconnectTimestamp

      private volatile long nextReconnectTimestamp
  • Constructor Details

    • ReconnectRequest

      public ReconnectRequest(InetSocketAddressWrapper inetSocketAddressWrapper, int tries, long reconnectInterval)
  • Method Details

    • normalInterval

      private long normalInterval(long reconnectInterval)
    • getDelay

      public long getDelay(TimeUnit unit)
      Specified by:
      getDelay in interface Delayed
    • compareTo

      public int compareTo(Delayed o)
      Specified by:
      compareTo in interface Comparable<Delayed>
    • getInetSocketAddressWrapper

      public final InetSocketAddressWrapper getInetSocketAddressWrapper()
      Returns a reconnect socket address wrapper
      Returns:
      See Also:
    • updateNextReconnectTimeStamp

      public void updateNextReconnectTimeStamp(long interval)
    • setInetSocketAddressWrapper

      public final void setInetSocketAddressWrapper(InetSocketAddressWrapper inetSocketAddressWrapper)
    • setTries

      public final void setTries(int tries)
    • getTries

      public final int getTries()
      Returns retry times
      Returns:
      retry times,it is zero if it does not retry to connect