com.datastax.driver.core.policies

Class ConstantReconnectionPolicy

java.lang.Object

com.datastax.driver.core.policies.ConstantReconnectionPolicy

All Implemented Interfaces:

ReconnectionPolicy

public class ConstantReconnectionPolicy
extends Object
implements ReconnectionPolicy

A reconnection policy that waits a constant time between each reconnection attempt.

Nested Class Summary

Nested classes/interfaces inherited from interface com.datastax.driver.core.policies.ReconnectionPolicy

ReconnectionPolicy.ReconnectionSchedule

Constructor Summary

Constructors

Constructor and Description
ConstantReconnectionPolicy(long constantDelayMs) Creates a reconnection policy that creates with the provided constant wait time between reconnection attempts.

Method Summary

Modifier and Type	Method and Description
void	close() Gets invoked at cluster shutdown.
long	getConstantDelayMs() The constant delay used by this reconnection policy.
void	init(Cluster cluster) Gets invoked at cluster startup.
ReconnectionPolicy.ReconnectionSchedule	newSchedule() A new schedule that uses a constant getConstantDelayMs() delay between reconnection attempt.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConstantReconnectionPolicy

public ConstantReconnectionPolicy(long constantDelayMs)

Creates a reconnection policy that creates with the provided constant wait time between reconnection attempts.

Parameters:

constantDelayMs - the constant delay in milliseconds to use.

Method Detail

getConstantDelayMs

public long getConstantDelayMs()

The constant delay used by this reconnection policy.

Returns:

the constant delay used by this reconnection policy.

newSchedule

public ReconnectionPolicy.ReconnectionSchedule newSchedule()

A new schedule that uses a constant getConstantDelayMs() delay between reconnection attempt.

Specified by:

newSchedule in interface ReconnectionPolicy

Returns:

the newly created schedule.

init

public void init(Cluster cluster)

Description copied from interface: ReconnectionPolicy

Gets invoked at cluster startup.

Specified by:

init in interface ReconnectionPolicy

Parameters:

cluster - the cluster that this policy is associated with.

close

public void close()

Description copied from interface: ReconnectionPolicy

Gets invoked at cluster shutdown.

This gives the policy the opportunity to perform some cleanup, for instance stop threads that it might have started.

Specified by:

close in interface ReconnectionPolicy