public class L1ManagerImpl extends Object implements L1Manager, RemoteValueRetrievedListener
Constructor and Description |
---|
L1ManagerImpl() |
Modifier and Type | Method and Description |
---|---|
void |
addRequestor(Object key,
Address origin)
Records a request that will be cached in another nodes L1
|
Future<Object> |
flushCache(Collection<Object> keys,
Address origin,
boolean assumeOriginKeptEntryInL1) |
Future<Object> |
flushCacheWithSimpleFuture(Collection<Object> keys,
Object retval,
Address origin,
boolean assumeOriginKeptEntryInL1) |
void |
init(Configuration configuration,
RpcManager rpcManager,
CommandsFactory commandsFactory,
ExecutorService asyncTransportExecutor,
ScheduledExecutorService scheduledExecutor,
TimeService timeService) |
void |
registerL1WriteSynchronizer(Object key,
L1WriteSynchronizer sync)
Registers the given write synchronizer to be notified whenever a remote value is looked up for the given key.
|
void |
remoteValueFound(InternalCacheEntry ice)
Invoked when a remote value is found from a remote source
|
void |
start() |
void |
stop() |
void |
unregisterL1WriteSynchronizer(Object key,
L1WriteSynchronizer sync)
Unregister the given write synchronizer if present.
|
public void init(Configuration configuration, RpcManager rpcManager, CommandsFactory commandsFactory, ExecutorService asyncTransportExecutor, ScheduledExecutorService scheduledExecutor, TimeService timeService)
public void start()
public void stop()
public void addRequestor(Object key, Address origin)
L1Manager
addRequestor
in interface L1Manager
public Future<Object> flushCacheWithSimpleFuture(Collection<Object> keys, Object retval, Address origin, boolean assumeOriginKeptEntryInL1)
flushCacheWithSimpleFuture
in interface L1Manager
public Future<Object> flushCache(Collection<Object> keys, Address origin, boolean assumeOriginKeptEntryInL1)
flushCache
in interface L1Manager
public void registerL1WriteSynchronizer(Object key, L1WriteSynchronizer sync)
L1Manager
L1Manager.unregisterL1WriteSynchronizer(Object, org.infinispan.interceptors.distribution.L1WriteSynchronizer)
registerL1WriteSynchronizer
in interface L1Manager
key
- The key that that when looked up will trigger the synchronizersync
- The synchronizer to run the update when the key is looked uppublic void unregisterL1WriteSynchronizer(Object key, L1WriteSynchronizer sync)
L1Manager
unregisterL1WriteSynchronizer
in interface L1Manager
key
- The key to unregister the given synchronizer for.sync
- The synchronizer to be removed if it is still present.public void remoteValueFound(InternalCacheEntry ice)
RemoteValueRetrievedListener
remoteValueFound
in interface RemoteValueRetrievedListener
ice
- The cache entry that was foundCopyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.