|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.jcs.auxiliary.lateral.socket.tcp.LateralTCPListener
Listens for connections from other TCP lateral caches and handles them.
Nested Class Summary | |
class |
LateralTCPListener.ConnectionHandler
Separate thread run when a command comes into the LateralTCPReceiver. |
class |
LateralTCPListener.ListenerThread
Processes commands from the server socket. |
Field Summary | |
private static int |
acceptTimeOut
How long the server will block on an accept(). |
protected static CompositeCacheManager |
cacheMgr
The CacheHub this listener is associated with |
private ILateralCacheAttributes |
ilca
|
protected static java.util.HashMap |
instances
Map of available instances, keyed by port |
private static org.apache.commons.logging.Log |
log
|
private EDU.oswego.cs.dl.util.concurrent.PooledExecutor |
pooledExecutor
|
private int |
port
|
private LateralTCPListener.ListenerThread |
receiver
The socket listener |
Constructor Summary | |
protected |
LateralTCPListener(ILateralCacheAttributes ilca)
Only need one since it does work for all regions, just reference by multiple region names. |
Method Summary | |
protected CompositeCache |
getCache(java.lang.String name)
Gets the cacheManager attribute of the LateralCacheTCPListener object |
static ILateralCacheListener |
getInstance(ILateralCacheAttributes ilca)
Gets the instance attribute of the LateralCacheTCPListener class |
byte |
getListenerId()
Gets the listenerId attribute of the LateralCacheTCPListener object |
void |
handleDispose(java.lang.String cacheName)
Notifies the subscribers for freeing up the named cache. |
java.io.Serializable |
handleGet(java.lang.String cacheName,
java.io.Serializable key)
|
void |
handlePut(ICacheElement element)
Notifies the subscribers for a cache entry update. |
void |
handleRemove(java.lang.String cacheName,
java.io.Serializable key)
Notifies the subscribers for a cache entry removal. |
void |
handleRemoveAll(java.lang.String cacheName)
Notifies the subscribers for a cache remove-all. |
void |
init()
Description of the Method |
void |
setListenerId(byte id)
let the lateral cache set a listener_id. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
private static final org.apache.commons.logging.Log log
private static final int acceptTimeOut
protected static transient CompositeCacheManager cacheMgr
protected static final java.util.HashMap instances
private LateralTCPListener.ListenerThread receiver
private ILateralCacheAttributes ilca
private int port
private EDU.oswego.cs.dl.util.concurrent.PooledExecutor pooledExecutor
Constructor Detail |
protected LateralTCPListener(ILateralCacheAttributes ilca)
ilca
- Method Detail |
public static ILateralCacheListener getInstance(ILateralCacheAttributes ilca)
public void init()
init
in interface ILateralCacheListener
public void setListenerId(byte id) throws java.io.IOException
setListenerId
in interface ICacheListener
id
- The new listenerId value
java.io.IOException
public byte getListenerId() throws java.io.IOException
getListenerId
in interface ICacheListener
java.io.IOException
public void handlePut(ICacheElement element) throws java.io.IOException
ICacheListener
handlePut
in interface ICacheListener
java.io.IOException
public void handleRemove(java.lang.String cacheName, java.io.Serializable key) throws java.io.IOException
ICacheListener
handleRemove
in interface ICacheListener
java.io.IOException
public void handleRemoveAll(java.lang.String cacheName) throws java.io.IOException
ICacheListener
handleRemoveAll
in interface ICacheListener
java.io.IOException
public java.io.Serializable handleGet(java.lang.String cacheName, java.io.Serializable key) throws java.io.IOException
java.io.IOException
public void handleDispose(java.lang.String cacheName) throws java.io.IOException
ICacheListener
handleDispose
in interface ICacheListener
java.io.IOException
protected CompositeCache getCache(java.lang.String name)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |