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 Summary

Fields

Modifier and Type	Field	Description
private InetSocketAddressWrapper	inetSocketAddressWrapper
private static final long	MAX_RECONNECT_INTERVAL
private static final long	MIN_RECONNECT_INTERVAL
private long	nextReconnectTimestamp
private int	tries

Constructor Summary

Constructors

Constructor	Description
ReconnectRequest(InetSocketAddressWrapper inetSocketAddressWrapper, int tries, long reconnectInterval)

Method Summary

Modifier and Type	Method	Description
int	compareTo(Delayed o)
long	getDelay(TimeUnit unit)
final InetSocketAddressWrapper	getInetSocketAddressWrapper()	Returns a reconnect socket address wrapper
final int	getTries()	Returns retry times
private long	normalInterval(long reconnectInterval)
final void	setInetSocketAddressWrapper(InetSocketAddressWrapper inetSocketAddressWrapper)
final void	setTries(int tries)
void	updateNextReconnectTimeStamp(long interval)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

inetSocketAddressWrapper

private InetSocketAddressWrapper inetSocketAddressWrapper

tries

private int tries

MIN_RECONNECT_INTERVAL

private static final long MIN_RECONNECT_INTERVAL

See Also:

• Constant Field Values

MAX_RECONNECT_INTERVAL

private static final long MAX_RECONNECT_INTERVAL

See Also:

• Constant Field Values

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:

• InetSocketAddressWrapper

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