org.kaaproject.kaa.client.channel.failover.strategies

Class DefaultFailoverStrategy

java.lang.Object

org.kaaproject.kaa.client.channel.failover.strategies.DefaultFailoverStrategy

All Implemented Interfaces:

FailoverStrategy

public class DefaultFailoverStrategy
extends Object
implements FailoverStrategy

Reference implementation for FailoverStrategy.

Constructor Summary

Constructors

Constructor and Description
DefaultFailoverStrategy()
DefaultFailoverStrategy(long bootstrapServersRetryPeriod, long operationsServersRetryPeriod, long noConnectivityRetryPeriod, TimeUnit timeUnit)

Method Summary

Modifier and Type	Method and Description
long	getBootstrapServersRetryPeriod() Use the FailoverStrategy.getTimeUnit() method to get current time unit.
long	getOperationServersRetryPeriod() Use the FailoverStrategy.getTimeUnit() method to get current time unit.
TimeUnit	getTimeUnit()
FailoverDecision	onFailover(FailoverStatus failoverStatus) Needs to be invoked to determine a decision that resolves the failover.
void	onRecover(TransportConnectionInfo connectionInfo) Needs to be invoked once client recovered after failover.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultFailoverStrategy

public DefaultFailoverStrategy()

DefaultFailoverStrategy

public DefaultFailoverStrategy(long bootstrapServersRetryPeriod,
                               long operationsServersRetryPeriod,
                               long noConnectivityRetryPeriod,
                               TimeUnit timeUnit)

Method Detail

onFailover

public FailoverDecision onFailover(FailoverStatus failoverStatus)

Description copied from interface: FailoverStrategy

Needs to be invoked to determine a decision that resolves the failover.

Specified by:

onFailover in interface FailoverStrategy

Parameters:

failoverStatus - current status of the failover.

Returns:

decision which is meant to resolve the failover.

See Also:

FailoverDecision, FailoverStatus

onRecover

public void onRecover(TransportConnectionInfo connectionInfo)

Description copied from interface: FailoverStrategy

Needs to be invoked once client recovered after failover.

Specified by:

onRecover in interface FailoverStrategy

Parameters:

connectionInfo - server information

See Also:

TransportConnectionInfo

getBootstrapServersRetryPeriod

public long getBootstrapServersRetryPeriod()

Description copied from interface: FailoverStrategy

Use the FailoverStrategy.getTimeUnit() method to get current time unit.

Specified by:

getBootstrapServersRetryPeriod in interface FailoverStrategy

Returns:

period of time after which will be made attempt to tweak bootstrap server.

getOperationServersRetryPeriod

public long getOperationServersRetryPeriod()

Description copied from interface: FailoverStrategy

Use the FailoverStrategy.getTimeUnit() method to get current time unit.

Specified by:

getOperationServersRetryPeriod in interface FailoverStrategy

Returns:

period of time after which will be made attempt to tweak operation server.

getTimeUnit

public TimeUnit getTimeUnit()

Specified by:

getTimeUnit in interface FailoverStrategy

Returns:

time unit used within a scope of current failover strategy.