org.infinispan.xsite
Class AbstractCustomFailurePolicy<K,V>

java.lang.Object
  org.infinispan.xsite.AbstractCustomFailurePolicy<K,V>

All Implemented Interfaces:

CustomFailurePolicy<K,V>

public abstract class AbstractCustomFailurePolicy<K,V>
extends Object
implements CustomFailurePolicy<K,V>

Support class for CustomFailurePolicy.

Since:

5.2

Author:

Mircea Markus

Field Summary

protected Cache<K,V>

cache

Constructor Summary

AbstractCustomFailurePolicy()

Method Summary

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 cache) Invoked during the initialization phase.

Methods inherited from class java.lang.Object

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

Field Detail

cache

protected volatile Cache<K,V> cache

Constructor Detail

AbstractCustomFailurePolicy

public AbstractCustomFailurePolicy()

Method Detail

init

public void init(Cache cache)

Description copied from interface: CustomFailurePolicy

Invoked during the initialization phase.

Specified by:

init in interface CustomFailurePolicy<K,V>

handlePutFailure

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

Specified by:

handlePutFailure in interface CustomFailurePolicy<K,V>

handleRemoveFailure

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

Specified by:

handleRemoveFailure in interface CustomFailurePolicy<K,V>

handleReplaceFailure

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

Specified by:

handleReplaceFailure in interface CustomFailurePolicy<K,V>

handleClearFailure

public void handleClearFailure(String site)

Specified by:

handleClearFailure in interface CustomFailurePolicy<K,V>

handlePutAllFailure

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

Specified by:

handlePutAllFailure in interface CustomFailurePolicy<K,V>

handlePrepareFailure

public void handlePrepareFailure(String site,
                                 Transaction transaction)

Specified by:

handlePrepareFailure in interface CustomFailurePolicy<K,V>

handleRollbackFailure

public void handleRollbackFailure(String site,
                                  Transaction transaction)

Specified by:

handleRollbackFailure in interface CustomFailurePolicy<K,V>

handleCommitFailure

public void handleCommitFailure(String site,
                                Transaction transaction)

Specified by:

handleCommitFailure in interface CustomFailurePolicy<K,V>