org.infinispan.xsite

Interface CustomFailurePolicy<K,V>

All Known Implementing Classes:

AbstractCustomFailurePolicy

public interface CustomFailurePolicy<K,V>

Used for implementing custom policies in case of communication failures with a remote site. The handle methods are allowed to throw instances of BackupFailureException to signal that they want the intra-site operation to fail as well. If handle methods don't throw any exception then the operation will succeed in the local cluster. For convenience, there is a support implementation of this class: AbstractCustomFailurePolicy

Lifecycle: the same instance is invoked during the lifecycle of a cache so it is allowed to hold state between invocations.

Threadsafety: instances of this class might be invoked from different threads and they should be synchronized.

Since:

5.2

Author:

Mircea Markus

See Also:

BackupFailureException

Method Summary

Methods

Modifier and Type	Method and Description
void	handleClearFailure(String site)
void	handleCommitFailure(String site, Transaction transaction)
void	handlePrepareFailure(String site, Transaction transaction)
void	handlePutAllFailure(String site, Map<K,V> map)
void	handlePutFailure(String site, K key, V value, boolean putIfAbsent)
void	handleRemoveFailure(String site, K key, V oldValue)
void	handleReplaceFailure(String site, K key, V oldValue, V newValue)
void	handleRollbackFailure(String site, Transaction transaction)
void	init(Cache<K,V> cache) Invoked during the initialization phase.

Method Detail

init

void init(Cache<K,V> cache)

Invoked during the initialization phase.

handlePutFailure

void handlePutFailure(String site,
                    K key,
                    V value,
                    boolean putIfAbsent)

handleRemoveFailure

void handleRemoveFailure(String site,
                       K key,
                       V oldValue)

handleReplaceFailure

void handleReplaceFailure(String site,
                        K key,
                        V oldValue,
                        V newValue)

handleClearFailure

void handleClearFailure(String site)

handlePutAllFailure

void handlePutAllFailure(String site,
                       Map<K,V> map)

handlePrepareFailure

void handlePrepareFailure(String site,
                        Transaction transaction)

handleRollbackFailure

void handleRollbackFailure(String site,
                         Transaction transaction)

handleCommitFailure

void handleCommitFailure(String site,
                       Transaction transaction)