org.apache.jcs.engine
Class CacheWatchRepairable

java.lang.Object
  org.apache.jcs.engine.CacheWatchRepairable

All Implemented Interfaces:

ICacheObserver

Direct Known Subclasses:

LateralCacheWatchRepairable, RemoteCacheWatchRepairable

public class CacheWatchRepairable

extends java.lang.Object

implements ICacheObserver

Interceps the requests to the underlying ICacheObserver object so that the listeners can be recorded locally for remote connection recovery purposes. (Durable subscription like those in JMS is not implemented at this stage for it can be too expensive on the runtime.)

Author:

asmuts

Field Summary

private java.util.Map	cacheMap
private ICacheObserver	cacheWatch
private static org.apache.commons.logging.Log	log

Constructor Summary

CacheWatchRepairable()

Method Summary

void	addCacheListener(ICacheListener obj) Adds a feature to the CacheListener attribute of the CacheWatchRepairable object
void	addCacheListener(java.lang.String cacheName, ICacheListener obj) Adds a feature to the CacheListener attribute of the CacheWatchRepairable object
void	removeCacheListener(ICacheListener obj) Description of the Method
void	removeCacheListener(java.lang.String cacheName, ICacheListener obj) Description of the Method
void	setCacheWatch(ICacheObserver cacheWatch) Replaces the underlying cache watch service and reattached all existing listeners to the new cache watch.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

private static final org.apache.commons.logging.Log log

cacheWatch

private ICacheObserver cacheWatch

cacheMap

private java.util.Map cacheMap

Constructor Detail

CacheWatchRepairable

public CacheWatchRepairable()

Method Detail

setCacheWatch

public void setCacheWatch(ICacheObserver cacheWatch)

Replaces the underlying cache watch service and reattached all existing listeners to the new cache watch.

Parameters:

cacheWatch - The new cacheWatch value

addCacheListener

public void addCacheListener(java.lang.String cacheName,
                             ICacheListener obj)
                      throws java.io.IOException

Adds a feature to the CacheListener attribute of the CacheWatchRepairable object

Specified by:

addCacheListener in interface ICacheObserver

Parameters:

cacheName - The feature to be added to the CacheListener attribute

obj - The feature to be added to the CacheListener attribute

Throws:

java.io.IOException

addCacheListener

public void addCacheListener(ICacheListener obj)
                      throws java.io.IOException

Adds a feature to the CacheListener attribute of the CacheWatchRepairable object

Specified by:

addCacheListener in interface ICacheObserver

Parameters:

obj - The feature to be added to the CacheListener attribute

Throws:

java.io.IOException

removeCacheListener

public void removeCacheListener(java.lang.String cacheName,
                                ICacheListener obj)
                         throws java.io.IOException

Description of the Method

Specified by:

removeCacheListener in interface ICacheObserver

Parameters:

obj - existing subscriber.

Throws:

java.io.IOException

removeCacheListener

public void removeCacheListener(ICacheListener obj)
                         throws java.io.IOException

Description of the Method

Specified by:

removeCacheListener in interface ICacheObserver

Parameters:

obj - existing subscriber.

Throws:

java.io.IOException