public class RemoteHttpCacheService<K,V> extends AbstractRemoteCacheService<K,V>
For now we assume that all clients are non-cluster clients. And listener notification is not supported.
Constructor and Description |
---|
RemoteHttpCacheService(ICompositeCacheManager cacheManager,
RemoteHttpCacheServerAttributes remoteHttpCacheServerAttributes,
ICacheEventLogger cacheEventLogger)
Create a process with a cache manager.
|
Modifier and Type | Method and Description |
---|---|
protected String |
getExtraInfoForRequesterId(long requesterId)
This is called by the event log.
|
void |
processDispose(String cacheName,
long requesterId)
Processes a shutdown request.
|
ICacheElement<K,V> |
processGet(String cacheName,
K key,
long requesterId)
Processes a get request.
|
Map<K,ICacheElement<K,V>> |
processGetMatching(String cacheName,
String pattern,
long requesterId)
Processes a get request.
|
Map<K,ICacheElement<K,V>> |
processGetMultiple(String cacheName,
Set<K> keys,
long requesterId)
Processes a get request.
|
void |
processRemove(String cacheName,
K key,
long requesterId)
Processes a remove request.
|
void |
processRemoveAll(String cacheName,
long requesterId)
Processes a removeAll request.
|
void |
processUpdate(ICacheElement<K,V> item,
long requesterId)
Processes an update request.
|
void |
release()
This general method should be deprecated.
|
createICacheEvent, createICacheEvent, dispose, dispose, get, get, getCacheManager, getEventLogSourceName, getKeySet, getMatching, getMatching, getMultiple, getMultiple, getStats, logApplicationEvent, logICacheEvent, processGetKeySet, remove, remove, removeAll, removeAll, setCacheEventLogger, setCacheManager, setEventLogSourceName, update, update
public RemoteHttpCacheService(ICompositeCacheManager cacheManager, RemoteHttpCacheServerAttributes remoteHttpCacheServerAttributes, ICacheEventLogger cacheEventLogger)
cacheManager
- remoteHttpCacheServerAttributes
- cacheEventLogger
- public ICacheElement<K,V> processGet(String cacheName, K key, long requesterId) throws IOException
If isAllowClusterGet is enabled we will treat this as a normal request or non-remote origins.
cacheName
- key
- requesterId
- IOException
public Map<K,ICacheElement<K,V>> processGetMultiple(String cacheName, Set<K> keys, long requesterId) throws IOException
If isAllowClusterGet is enabled we will treat this as a normal request of non-remote origination.
cacheName
- keys
- requesterId
- IOException
public Map<K,ICacheElement<K,V>> processGetMatching(String cacheName, String pattern, long requesterId) throws IOException
If isAllowClusterGet is enabled we will treat this as a normal request of non-remote origination.
cacheName
- pattern
- requesterId
- IOException
public void processUpdate(ICacheElement<K,V> item, long requesterId) throws IOException
If isLocalClusterConsistency is enabled we will treat this as a normal request of non-remote origination.
item
- requesterId
- IOException
public void processRemove(String cacheName, K key, long requesterId) throws IOException
If isLocalClusterConsistency is enabled we will treat this as a normal request of non-remote origination.
cacheName
- key
- requesterId
- IOException
public void processRemoveAll(String cacheName, long requesterId) throws IOException
If isLocalClusterConsistency is enabled we will treat this as a normal request of non-remote origination.
cacheName
- requesterId
- IOException
public void processDispose(String cacheName, long requesterId) throws IOException
cacheName
- requesterId
- IOException
public void release() throws IOException
IOException
protected String getExtraInfoForRequesterId(long requesterId)
getExtraInfoForRequesterId
in class AbstractRemoteCacheService<K,V>
requesterId
- Copyright © 2002–2018 The Apache Software Foundation. All rights reserved.