org.tio.client

Class ReconnConf

java.lang.Object

org.tio.client.ReconnConf

public class ReconnConf
extends Object

Author:

tanyaowu 2017年4月1日 上午9:33:00

Constructor Summary

Constructors

Constructor and Description
ReconnConf()
ReconnConf(long interval)
ReconnConf(long interval, int retryCount)

Method Summary

Modifier and Type	Method and Description
long	getInterval()
LinkedBlockingQueue<ChannelContext>	getQueue()
static ReconnConf	getReconnConf(ChannelContext channelContext)
static ReconnConf	getReconnConf(ClientChannelContext clientChannelContext)
int	getRetryCount() 连续重连次数，当连续重连这么多次都失败时，不再重连。0和负数则一直重连
SynThreadPoolExecutor	getThreadPoolExecutor()
static boolean	isNeedReconn(ClientChannelContext clientChannelContext, boolean putIfNeedConn)
static boolean	put(ClientChannelContext clientChannelContext)
void	setInterval(long interval)
void	setRetryCount(int retryCount) 连续重连次数，当连续重连这么多次都失败时，不再重连。0和负数则一直重连

Methods inherited from class java.lang.Object

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

Constructor Detail

ReconnConf

public ReconnConf()

ReconnConf

public ReconnConf(long interval)

Parameters:

interval -

ReconnConf

public ReconnConf(long interval,
                  int retryCount)

Parameters:

interval -

retryCount -

Method Detail

getReconnConf

public static ReconnConf getReconnConf(ClientChannelContext clientChannelContext)

getReconnConf

public static ReconnConf getReconnConf(ChannelContext channelContext)

isNeedReconn

public static boolean isNeedReconn(ClientChannelContext clientChannelContext,
                                   boolean putIfNeedConn)

Parameters:

clientChannelContext -

putIfNeedConn - 如果需要重连，则把该ClientChannelContext放到重连队列中

Returns:

put

public static boolean put(ClientChannelContext clientChannelContext)

Parameters:

clientChannelContext -

Returns:

true:需要重连; false:不需要重连

getInterval

public long getInterval()

Returns:

the interval

getQueue

public LinkedBlockingQueue<ChannelContext> getQueue()

Returns:

the queue

getRetryCount

public int getRetryCount()

连续重连次数，当连续重连这么多次都失败时，不再重连。0和负数则一直重连

Returns:

the retryCount

getThreadPoolExecutor

public SynThreadPoolExecutor getThreadPoolExecutor()

Returns:

the threadPoolExecutor

setInterval

public void setInterval(long interval)

Parameters:

interval - the interval to set

setRetryCount

public void setRetryCount(int retryCount)

连续重连次数，当连续重连这么多次都失败时，不再重连。0和负数则一直重连

Parameters:

retryCount - the retryCount to set