Package org.infinispan.xsite
Class BaseBackupReceiver
- java.lang.Object
-
- org.infinispan.xsite.BaseBackupReceiver
-
- All Implemented Interfaces:
BackupReceiver
- Direct Known Subclasses:
ClusteredCacheBackupReceiver
,LocalCacheBackupReceiver
public abstract class BaseBackupReceiver extends Object implements BackupReceiver
Common implementation logic forBackupReceiver
- Since:
- 7.1
- Author:
- Mircea Markus, Pedro Ruivo
-
-
Field Summary
Fields Modifier and Type Field Description protected AdvancedCache<Object,Object>
cache
protected ByteString
cacheName
protected org.infinispan.commons.time.TimeService
timeService
-
Constructor Summary
Constructors Modifier Constructor Description protected
BaseBackupReceiver(Cache<Object,Object> cache)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
assertAllowInvocation()
Cache
getCache()
Object
handleRemoteCommand(VisitableCommand command)
protected static XSiteStatePushCommand
newStatePushCommand(AdvancedCache<?,?> cache, List<XSiteState> stateList)
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.infinispan.xsite.BackupReceiver
handleStateTransferControl, handleStateTransferState
-
-
-
-
Field Detail
-
cache
protected final AdvancedCache<Object,Object> cache
-
cacheName
protected final ByteString cacheName
-
timeService
protected final org.infinispan.commons.time.TimeService timeService
-
-
Method Detail
-
newStatePushCommand
protected static XSiteStatePushCommand newStatePushCommand(AdvancedCache<?,?> cache, List<XSiteState> stateList)
-
getCache
public final Cache getCache()
- Specified by:
getCache
in interfaceBackupReceiver
-
handleRemoteCommand
public final Object handleRemoteCommand(VisitableCommand command) throws Throwable
- Specified by:
handleRemoteCommand
in interfaceBackupReceiver
- Throws:
Throwable
-
assertAllowInvocation
protected final void assertAllowInvocation()
-
-