org.kaaproject.kaa.client.channel.impl

Class DefaultFailoverManager

java.lang.Object

org.kaaproject.kaa.client.channel.impl.DefaultFailoverManager

All Implemented Interfaces:

FailoverManager

public class DefaultFailoverManager
extends Object
implements FailoverManager

Constructor Summary

Constructors

Constructor and Description
DefaultFailoverManager(KaaChannelManager channelManager, ExecutorContext context)
DefaultFailoverManager(KaaChannelManager channelManager, ExecutorContext context, long failureResolutionTimeout, long bootstrapServersRetryPeriod, long operationsServersRetryPeriod, long noConnectivityRetryPeriod, TimeUnit timeUnit)

Method Summary

Methods

Modifier and Type	Method and Description
FailoverDecision	onFailover(FailoverStatus failoverStatus) Needs to be invoked to determine a decision that resolves the failover.
void	onServerChanged(TransportConnectionInfo connectionInfo) Needs to be invoked as soon as current server is changed.
void	onServerConnected(TransportConnectionInfo connectionInfo) Needs to be invoked as soon as connection to the current server is established.
void	onServerFailed(TransportConnectionInfo connectionInfo) Needs to be invoked when a server fail occurs.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultFailoverManager

public DefaultFailoverManager(KaaChannelManager channelManager,
                      ExecutorContext context)

DefaultFailoverManager

public DefaultFailoverManager(KaaChannelManager channelManager,
                      ExecutorContext context,
                      long failureResolutionTimeout,
                      long bootstrapServersRetryPeriod,
                      long operationsServersRetryPeriod,
                      long noConnectivityRetryPeriod,
                      TimeUnit timeUnit)

Method Detail

onServerFailed

public void onServerFailed(TransportConnectionInfo connectionInfo)

Description copied from interface: FailoverManager

Needs to be invoked when a server fail occurs.

Specified by:

onServerFailed in interface FailoverManager

Parameters:

connectionInfo - the connection information of the failed server.

See Also:

TransportConnectionInfo

onServerChanged

public void onServerChanged(TransportConnectionInfo connectionInfo)

Description copied from interface: FailoverManager

Needs to be invoked as soon as current server is changed.

Specified by:

onServerChanged in interface FailoverManager

Parameters:

connectionInfo - the connection information of the newly connected server.

See Also:

TransportConnectionInfo

onServerConnected

public void onServerConnected(TransportConnectionInfo connectionInfo)

Description copied from interface: FailoverManager

Needs to be invoked as soon as connection to the current server is established.

Specified by:

onServerConnected in interface FailoverManager

Parameters:

connectionInfo - the connection information of the current server, to which connection was successfully established.

See Also:

TransportConnectionInfo

onFailover

public FailoverDecision onFailover(FailoverStatus failoverStatus)

Description copied from interface: FailoverManager

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

Specified by:

onFailover in interface FailoverManager

Parameters:

failoverStatus - current status of the failover.

Returns:

decision which is meant to resolve the failover.

See Also:

FailoverDecision, FailoverStatus