co.cask.cdap.notifications.service

Class TxRetryPolicy

java.lang.Object

co.cask.cdap.notifications.service.TxRetryPolicy

public abstract class TxRetryPolicy
extends Object

Retry policy object used by the NotificationContext.execute(co.cask.cdap.api.TxRunnable, co.cask.cdap.notifications.service.TxRetryPolicy) method to specify behavior when transaction execution fails.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TxRetryPolicy.Policy Failure policy option enum.

Constructor Summary

Constructors

Constructor and Description
TxRetryPolicy()

Method Summary

Methods

Modifier and Type	Method and Description
abstract TxRetryPolicy.Policy	handleFailure(int failures, Throwable e) Specify how failure should be handled.
static TxRetryPolicy	maxRetries(int tries) Create a TxRetryPolicy object that retries a maximum of tries.

Methods inherited from class java.lang.Object

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

Constructor Detail

TxRetryPolicy

public TxRetryPolicy()

Method Detail

handleFailure

public abstract TxRetryPolicy.Policy handleFailure(int failures,
                                 Throwable e)

Specify how failure should be handled.

Parameters:

failures - number of failures so far, including this one

e - exception that caused the failure

Returns:

a TxRetryPolicy.Policy code indicating what action should be done

maxRetries

public static TxRetryPolicy maxRetries(int tries)

Create a TxRetryPolicy object that retries a maximum of tries.

Parameters:

tries - number of tries before dropping a transaction

Returns:

a TxRetryPolicy object that will drop after the given amount of tries