Class BaseBackupInterceptor
- java.lang.Object
-
- org.infinispan.interceptors.BaseAsyncInterceptor
-
- org.infinispan.interceptors.DDAsyncInterceptor
-
- org.infinispan.interceptors.xsite.BaseBackupInterceptor
-
- All Implemented Interfaces:
org.infinispan.commands.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 org.infinispan.util.logging.Log
log
protected static boolean
trace
protected org.infinispan.transaction.impl.TransactionTable
txTable
-
Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor
cacheConfiguration
-
-
Constructor Summary
Constructors Constructor Description BaseBackupInterceptor()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.infinispan.util.logging.Log
getLog()
protected boolean
isTxFromRemoteSite(GlobalTransaction gtx)
protected Object
processBackupResponse(org.infinispan.context.impl.TxInvocationContext ctx, org.infinispan.commands.VisitableCommand command, BackupResponse backupResponse)
protected boolean
shouldInvokeRemoteTxCommand(org.infinispan.context.impl.TxInvocationContext ctx)
protected boolean
skipXSiteBackup(org.infinispan.commands.FlagAffectedCommand command)
Object
visitClearCommand(InvocationContext ctx, org.infinispan.commands.write.ClearCommand command)
Object
visitPrepareCommand(org.infinispan.context.impl.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
-
-
-
-
Field Detail
-
backupSender
protected BackupSender backupSender
-
txTable
protected org.infinispan.transaction.impl.TransactionTable txTable
-
log
protected static final org.infinispan.util.logging.Log log
-
trace
protected static final boolean trace
-
-
Method Detail
-
visitClearCommand
public final Object visitClearCommand(InvocationContext ctx, org.infinispan.commands.write.ClearCommand command) throws Throwable
- Specified by:
visitClearCommand
in interfaceorg.infinispan.commands.Visitor
- Overrides:
visitClearCommand
in classDDAsyncInterceptor
- Throws:
Throwable
-
visitPrepareCommand
public Object visitPrepareCommand(org.infinispan.context.impl.TxInvocationContext ctx, org.infinispan.commands.tx.PrepareCommand command) throws Throwable
- Specified by:
visitPrepareCommand
in interfaceorg.infinispan.commands.Visitor
- Overrides:
visitPrepareCommand
in classDDAsyncInterceptor
- Throws:
Throwable
-
processBackupResponse
protected Object processBackupResponse(org.infinispan.context.impl.TxInvocationContext ctx, org.infinispan.commands.VisitableCommand command, BackupResponse backupResponse)
-
isTxFromRemoteSite
protected boolean isTxFromRemoteSite(GlobalTransaction gtx)
-
shouldInvokeRemoteTxCommand
protected boolean shouldInvokeRemoteTxCommand(org.infinispan.context.impl.TxInvocationContext ctx)
-
skipXSiteBackup
protected final boolean skipXSiteBackup(org.infinispan.commands.FlagAffectedCommand command)
-
getLog
protected org.infinispan.util.logging.Log getLog()
-
-