Package org.infinispan.interceptors.xsite

Class BaseBackupInterceptor

java.lang.Object

org.infinispan.interceptors.BaseAsyncInterceptor

org.infinispan.interceptors.DDAsyncInterceptor

org.infinispan.interceptors.xsite.BaseBackupInterceptor

All Implemented Interfaces:

Visitor, AsyncInterceptor

Direct Known Subclasses:

NonTransactionalBackupInterceptor, OptimisticBackupInterceptor, PessimisticBackupInterceptor

public class BaseBackupInterceptor
extends DDAsyncInterceptor

Since:

5.2

Author:

Mircea Markus

Field Summary

Fields

Modifier and Type	Field	Description
protected BackupSender	backupSender
protected static Log	log
protected static boolean	trace
protected TransactionTable	txTable

Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor	Description
BaseBackupInterceptor()

Method Summary

Modifier and Type	Method	Description
protected Log	getLog()
protected boolean	isTxFromRemoteSite(GlobalTransaction gtx)
protected Object	processBackupResponse(TxInvocationContext ctx, VisitableCommand command, BackupResponse backupResponse)
protected boolean	shouldInvokeRemoteTxCommand(TxInvocationContext ctx)
protected boolean	skipXSiteBackup(FlagAffectedCommand command)
Object	visitClearCommand(InvocationContext ctx, org.infinispan.commands.write.ClearCommand command)
Object	visitPrepareCommand(TxInvocationContext ctx, org.infinispan.commands.tx.PrepareCommand command)

Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor

handleDefault, visitCommand, visitCommitCommand, visitComputeCommand, visitComputeIfAbsentCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitGetAllCommand, visitGetCacheEntryCommand, visitGetKeysInGroupCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPutKeyValueCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand

Methods inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

asyncInvokeNext, asyncInvokeNext, asyncInvokeNext, asyncValue, delayedValue, delayedValue, invokeNext, invokeNextAndExceptionally, invokeNextAndFinally, invokeNextAndHandle, invokeNextThenAccept, invokeNextThenApply, isSuccessfullyDone, makeStage, setNextInterceptor, valueOrException

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.commands.Visitor

visitApplyDeltaCommand, visitRemoveExpiredCommand

Field Detail

backupSender

protected BackupSender backupSender

txTable

protected TransactionTable txTable

log

protected static final Log log

trace

protected static final boolean trace

Constructor Detail

BaseBackupInterceptor

public BaseBackupInterceptor()

Method Detail

visitClearCommand

public final Object visitClearCommand(InvocationContext ctx,
                                      org.infinispan.commands.write.ClearCommand command)
                               throws Throwable

Specified by:

visitClearCommand in interface Visitor

Overrides:

visitClearCommand in class DDAsyncInterceptor

Throws:

Throwable

visitPrepareCommand

public Object visitPrepareCommand(TxInvocationContext ctx,
                                  org.infinispan.commands.tx.PrepareCommand command)
                           throws Throwable

Specified by:

visitPrepareCommand in interface Visitor

Overrides:

visitPrepareCommand in class DDAsyncInterceptor

Throws:

Throwable

processBackupResponse

protected Object processBackupResponse(TxInvocationContext ctx,
                                       VisitableCommand command,
                                       BackupResponse backupResponse)

isTxFromRemoteSite

protected boolean isTxFromRemoteSite(GlobalTransaction gtx)

shouldInvokeRemoteTxCommand

protected boolean shouldInvokeRemoteTxCommand(TxInvocationContext ctx)

skipXSiteBackup

protected final boolean skipXSiteBackup(FlagAffectedCommand command)

getLog

protected Log getLog()