com.datastax.driver.dse

Class LoggingIdempotenceAwareRetryPolicy

java.lang.Object

com.datastax.driver.core.policies.IdempotenceAwareRetryPolicy

com.datastax.driver.dse.LoggingIdempotenceAwareRetryPolicy

All Implemented Interfaces:

RetryPolicy

public class LoggingIdempotenceAwareRetryPolicy
extends IdempotenceAwareRetryPolicy

Add warnings to the parent policy.

We'll backport those warnings to driver-core in version 3.1.0, so this policy should become obsolete when driver-dse depends on 3.1.0.

Nested Class Summary

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

RetryPolicy.RetryDecision

Constructor Summary

Constructors

Constructor and Description
LoggingIdempotenceAwareRetryPolicy(RetryPolicy childPolicy) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	init(Cluster cluster) Gets invoked at cluster startup.
protected boolean	isIdempotent(Statement statement) Determines whether the given statement is idempotent or not.

Methods inherited from class com.datastax.driver.core.policies.IdempotenceAwareRetryPolicy

close, onReadTimeout, onRequestError, onUnavailable, onWriteTimeout

Methods inherited from class java.lang.Object

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

Constructor Detail

LoggingIdempotenceAwareRetryPolicy

public LoggingIdempotenceAwareRetryPolicy(RetryPolicy childPolicy)

Creates a new instance.

Parameters:

childPolicy - the policy to wrap.

Method Detail

init

public void init(Cluster cluster)

Description copied from interface: RetryPolicy

Gets invoked at cluster startup.

Specified by:

init in interface RetryPolicy

Overrides:

init in class IdempotenceAwareRetryPolicy

Parameters:

cluster - the cluster that this policy is associated with.

isIdempotent

protected boolean isIdempotent(Statement statement)

Description copied from class: IdempotenceAwareRetryPolicy

Determines whether the given statement is idempotent or not.

The current implementation inspects the statement's idempotent flag; if this flag is not set, then it inspects QueryOptions.getDefaultIdempotence().

Subclasses may override if they have better knowledge of the statement being executed.

Overrides:

isIdempotent in class IdempotenceAwareRetryPolicy

Parameters:

statement - The statement to execute.

Returns:

true if the given statement is idempotent, false otherwise