| java.lang.Object
 org.apache.catalina.cluster.ClusterSessionBase
org.apache.catalina.cluster.MulticastReceiver
| MulticastReceiver | | final public class MulticastReceiver extends ClusterSessionBase implements ClusterReceiver(Code) | | This class is responsible for checking for incoming multicast
data and determine if the data belongs to us and if so push
it onto an internal stack and let it be picked up when needed.
author:
Bip Thelin
version:
$Revision: 1.5 $, $Date: 2002/01/03 08:52:56 $ |
| Field Summary | |
| protected boolean | threadDone
The background thread completion semaphore. |
| threadDone | | protected boolean threadDone(Code) | | The background thread completion semaphore.
|
| MulticastReceiver | | MulticastReceiver(String senderId, MulticastSocket multicastSocket, InetAddress multicastAddress, int multicastPort)(Code) | | Create a new MulticastReceiver.
Parameters:
senderId - The unique senderId
Parameters:
multicastSocket - The MulticastSocket to use |
| getCheckInterval | | public int getCheckInterval()(Code) | | Get the time in seconds this Cluster sleeps
The time in seconds this Cluster sleeps |
| getName | | public String getName()(Code) | | Return a String containing the name of this
implementation, used for logging
The name of the implementation |
| getObjects | | public Object[] getObjects()(Code) | | Receive the objects currently in our stack and clear
if afterwards.
An array with objects |
| run | | public void run()(Code) | | The background thread.
|
| setCheckInterval | | public void setCheckInterval(int checkInterval)(Code) | | Set the time in seconds for this component to
Sleep before it checks for new received data in the Cluster
Parameters:
checkInterval - The time to sleep |
| start | | public void start()(Code) | | Start our component
|
| stop | | public void stop()(Code) | | Stop our component
|
|
|