org.apache.jcs.auxiliary.lateral.socket.tcp.discovery
Class UDPDiscoveryService

java.lang.Object
  org.apache.jcs.auxiliary.lateral.socket.tcp.discovery.UDPDiscoveryService

All Implemented Interfaces:

IShutdownObserver

public class UDPDiscoveryService

extends java.lang.Object

implements IShutdownObserver

This service creates a listener that can create lateral caches and add them to the no wait list.

It also creates a sender that periodically broadcasts its availability.

The sender also broadcasts a request for other caches to broadcast their addresses.

Author:

Aaron Smuts

Constructor Summary

UDPDiscoveryService(ITCPLateralCacheAttributes lca, ICompositeCacheManager cacheMgr)

Method Summary

protected void	addNoWait(LateralCacheNoWait noWait) This adds nowaits to a facde for the region name.
boolean	addNoWaitFacade(LateralCacheNoWaitFacade facade, java.lang.String cacheName) Adds a nowait facade under this cachename.
protected java.util.ArrayList	getCacheNames() Get all the cache names we have facades for.
ITCPLateralCacheAttributes	getTcpLateralCacheAttributes()
protected void	serviceRequestBroadcast() Send a passive broadcast in response to a request broadcast.
void	setTcpLateralCacheAttributes(ITCPLateralCacheAttributes lca)
void	shutdown() Tells the observer that the observable has received a shutdown command.

Methods inherited from class java.lang.Object

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

Constructor Detail

UDPDiscoveryService

public UDPDiscoveryService(ITCPLateralCacheAttributes lca,
                           ICompositeCacheManager cacheMgr)

Parameters:

lca - ITCPLateralCacheAttributes

cacheMgr -

Method Detail

addNoWaitFacade

public boolean addNoWaitFacade(LateralCacheNoWaitFacade facade,
                               java.lang.String cacheName)

Adds a nowait facade under this cachename. If one already existed, it will be overridden.

When a broadcast is received from the UDP Discovery receiver, for each cacheName in the message, the add no wait will be called here. To add a no wait, the facade is looked up for this cache name.

Parameters:

facade -

cacheName -

Returns:

true if the facade was not already registered.

addNoWait

protected void addNoWait(LateralCacheNoWait noWait)

This adds nowaits to a facde for the region name. If the region has no facade, then it is not configured to use the lateral cache, and no facde will be created.

Parameters:

noWait -

serviceRequestBroadcast

protected void serviceRequestBroadcast()

Send a passive broadcast in response to a request broadcast. Never send a request for a request. We can respond to our own reques, since a request broadcast is not intended as a connection request. We might want to only send messages, so we would send a request, but never a passive broadcast.

getCacheNames

protected java.util.ArrayList getCacheNames()

Get all the cache names we have facades for.

Returns:

setTcpLateralCacheAttributes

public void setTcpLateralCacheAttributes(ITCPLateralCacheAttributes lca)

Parameters:

lca - The lca to set.

getTcpLateralCacheAttributes

public ITCPLateralCacheAttributes getTcpLateralCacheAttributes()

Returns:

Returns the lca.

shutdown

public void shutdown()

Description copied from interface: IShutdownObserver

Tells the observer that the observable has received a shutdown command.

Specified by:

shutdown in interface IShutdownObserver