public interface ReconnectionPolicy
Each time a node is detected dead (because a connection error occurs), a new ReconnectionSchedule
instance is created (through the newSchedule()
). Then each call to
the ReconnectionPolicy.ReconnectionSchedule.nextDelayMs()
method of this instance will decide when the next
reconnection attempt to this node will be tried.
Note that if the driver receives a push notification from the Cassandra cluster that a node is
UP, any existing ReconnectionSchedule
on that node will be cancelled and a new one will
be created (in effect, the driver reset the scheduler).
The default ExponentialReconnectionPolicy
policy is usually adequate.
Modifier and Type | Interface and Description |
---|---|
static interface |
ReconnectionPolicy.ReconnectionSchedule
Schedules reconnection attempts to a node.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Gets invoked at cluster shutdown.
|
void |
init(Cluster cluster)
Gets invoked at cluster startup.
|
ReconnectionPolicy.ReconnectionSchedule |
newSchedule()
Creates a new schedule for reconnection attempts.
|
ReconnectionPolicy.ReconnectionSchedule newSchedule()
void init(Cluster cluster)
cluster
- the cluster that this policy is associated with.void close()
This gives the policy the opportunity to perform some cleanup, for instance stop threads that it might have started.
Copyright © 2012–2023. All rights reserved.