org.apache.jcs.auxiliary.remote.http.server
Class RemoteHttpCacheService<K extends Serializable,V extends Serializable>

java.lang.Object
  org.apache.jcs.auxiliary.remote.http.server.AbstractRemoteCacheService<K,V>
      org.apache.jcs.auxiliary.remote.http.server.RemoteHttpCacheService<K,V>

All Implemented Interfaces:

Remote, ICacheService<K,V>, ICacheServiceNonLocal<K,V>

public class RemoteHttpCacheService<K extends Serializable,V extends Serializable>
extends AbstractRemoteCacheService<K,V>

This does the work. It's called by the processor. The base class wraps the processing calls in event logs, if an event logger is present.

For now we assume that all clients are non-cluster clients. And listener notification is not supported.

RemoteHttpCacheService

public RemoteHttpCacheService(ICompositeCacheManager cacheManager,
                              RemoteHttpCacheServerAttributes remoteHttpCacheServerAttributes,
                              ICacheEventLogger cacheEventLogger)

Create a process with a cache manager.

Parameters:

cacheManager -

remoteHttpCacheServerAttributes -

cacheEventLogger -

processGet

public ICacheElement<K,V> processGet(String cacheName,
                                     K key,
                                     long requesterId)
                                                                        throws IOException

Processes a get request.

If isAllowClusterGet is enabled we will treat this as a normal request or non-remote origins.

Parameters:

cacheName -

key -

requesterId -

Returns:

ICacheElement

Throws:

IOException

processGetMultiple

public Map<K,ICacheElement<K,V>> processGetMultiple(String cacheName,
                                                    Set<K> keys,
                                                    long requesterId)
                                                                                                            throws IOException

Processes a get request.

If isAllowClusterGet is enabled we will treat this as a normal request of non-remote origination.

Parameters:

cacheName -

keys -

requesterId -

Returns:

Map

Throws:

IOException

processGetMatching

public Map<K,ICacheElement<K,V>> processGetMatching(String cacheName,
                                                    String pattern,
                                                    long requesterId)
                                                                                                            throws IOException

Processes a get request.

If isAllowClusterGet is enabled we will treat this as a normal request of non-remote origination.

Parameters:

cacheName -

pattern -

requesterId -

Returns:

Map

Throws:

IOException

processUpdate

public void processUpdate(ICacheElement<K,V> item,
                          long requesterId)
                   throws IOException

Processes an update request.

If isLocalClusterConsistency is enabled we will treat this as a normal request of non-remote origination.

Parameters:

item -

requesterId -

Throws:

IOException

processRemove

public void processRemove(String cacheName,
                          K key,
                          long requesterId)
                   throws IOException

Processes a remove request.

If isLocalClusterConsistency is enabled we will treat this as a normal request of non-remote origination.

Parameters:

cacheName -

key -

requesterId -

Throws:

IOException

processRemoveAll

public void processRemoveAll(String cacheName,
                             long requesterId)
                      throws IOException

Processes a removeAll request.

If isLocalClusterConsistency is enabled we will treat this as a normal request of non-remote origination.

Parameters:

cacheName -

requesterId -

Throws:

IOException

processDispose

public void processDispose(String cacheName,
                           long requesterId)
                    throws IOException

Processes a shutdown request.

Parameters:

cacheName -

requesterId -

Throws:

IOException

release

public void release()
             throws IOException

This general method should be deprecated.

Throws:

IOException

getExtraInfoForRequesterId

protected String getExtraInfoForRequesterId(long requesterId)

This is called by the event log.

Specified by:

getExtraInfoForRequesterId in class AbstractRemoteCacheService<K extends Serializable,V extends Serializable>

Parameters:

requesterId -

Returns:

requesterId + ""