Package net.rubyeye.xmemcached.impl
Class ReconnectRequest
java.lang.Object
net.rubyeye.xmemcached.impl.ReconnectRequest
- All Implemented Interfaces:
Comparable<Delayed>
,Delayed
A auto reconnect request,associating a socket address for reconnecting
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate InetSocketAddressWrapper
private static final long
private static final long
private long
private int
-
Constructor Summary
ConstructorsConstructorDescriptionReconnectRequest
(InetSocketAddressWrapper inetSocketAddressWrapper, int tries, long reconnectInterval) -
Method Summary
Modifier and TypeMethodDescriptionint
long
final InetSocketAddressWrapper
Returns a reconnect socket address wrapperfinal int
getTries()
Returns retry timesprivate long
normalInterval
(long reconnectInterval) final void
setInetSocketAddressWrapper
(InetSocketAddressWrapper inetSocketAddressWrapper) final void
setTries
(int tries) void
updateNextReconnectTimeStamp
(long interval)
-
Field Details
-
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
-
compareTo
- Specified by:
compareTo
in interfaceComparable<Delayed>
-
getInetSocketAddressWrapper
Returns a reconnect socket address wrapper- Returns:
- See Also:
-
updateNextReconnectTimeStamp
public void updateNextReconnectTimeStamp(long interval) -
setInetSocketAddressWrapper
-
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
-