org.apache.commons.jcs.engine

Class CacheWatchRepairable

java.lang.Object

org.apache.commons.jcs.engine.CacheWatchRepairable

All Implemented Interfaces:

ICacheObserver

public class CacheWatchRepairable
extends Object
implements ICacheObserver

Intercepts 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.)

Constructor Summary

Constructors

Constructor and Description
CacheWatchRepairable()

Method Summary

Modifier and Type	Method and Description
<K,V> void	addCacheListener(ICacheListener<K,V> obj) Adds a feature to the CacheListener attribute of the CacheWatchRepairable object
<K,V> void	addCacheListener(String cacheName, ICacheListener<K,V> obj) Adds a feature to the CacheListener attribute of the CacheWatchRepairable object
<K,V> void	removeCacheListener(ICacheListener<K,V> obj) Unsubscribes from all caches.
<K,V> void	removeCacheListener(String cacheName, ICacheListener<K,V> obj) Tell the server to release us.
void	setCacheWatch(ICacheObserver cacheWatch) Replaces the underlying cache watch service and re-attaches 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

Constructor Detail

CacheWatchRepairable

public CacheWatchRepairable()

Method Detail

setCacheWatch

public void setCacheWatch(ICacheObserver cacheWatch)

Replaces the underlying cache watch service and re-attaches all existing listeners to the new cache watch.

Parameters:

cacheWatch - The new cacheWatch value

addCacheListener

public <K,V> void addCacheListener(String cacheName,
                                   ICacheListener<K,V> obj)
                            throws 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:

IOException

addCacheListener

public <K,V> void addCacheListener(ICacheListener<K,V> obj)
                            throws 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:

IOException

removeCacheListener

public <K,V> void removeCacheListener(String cacheName,
                                      ICacheListener<K,V> obj)
                               throws IOException

Tell the server to release us.

Specified by:

removeCacheListener in interface ICacheObserver

Parameters:

cacheName -

obj -

Throws:

IOException

removeCacheListener

public <K,V> void removeCacheListener(ICacheListener<K,V> obj)
                               throws IOException

Description copied from interface: ICacheObserver

Unsubscribes from all caches.

Specified by:

removeCacheListener in interface ICacheObserver

Parameters:

obj -

Throws:

IOException