org.mmbase.clustering.multicast
Class Multicast

java.lang.Object
  extended by org.mmbase.clustering.ClusterManager
      extended by org.mmbase.clustering.multicast.Multicast
All Implemented Interfaces:
Runnable, AllEventListener, EventListener

public class Multicast
extends ClusterManager

Multicast is a thread object that reads the receive queue and spawns them to call the objects (listeners) who need to know. The Multicast start two threads to handle the sending and receiving of multicast messages.

Version:
$Id: Multicast.java 42844 2010-07-09 13:31:00Z michiel $
Author:
Daniel Ockeloen, Rico Jansen, Nico Klasens

Field Summary
static String CONFIG_FILE
           
static String HOST_DEFAULT
           
static int PORT_DEFAULT
           
 
Fields inherited from class org.mmbase.clustering.ClusterManager
compatible17, follownr, kicker, lastRecievedMessage, nodesToSend, nodesToSpawn, receive, send, spawnThreads
 
Constructor Summary
Multicast()
           
 
Method Summary
protected  void readConfiguration(Map<String,String> configuration)
          Read configuration settings
protected  void startCommunicationThreads()
          Subclasses should start the communication threads in this method
protected  void stopCommunicationThreads()
          Subclasses should stop the communication threads in this method
 String toString()
           
 
Methods inherited from class org.mmbase.clustering.ClusterManager
createMessage, createMessage, handleEvent, notify, parseMessage, parseMessageBackwardCompatible, run, shutdown, start
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

CONFIG_FILE

public static final String CONFIG_FILE
See Also:
Constant Field Values

HOST_DEFAULT

public static final String HOST_DEFAULT
See Also:
Constant Field Values

PORT_DEFAULT

public static final int PORT_DEFAULT
See Also:
Constant Field Values
Constructor Detail

Multicast

public Multicast()
Method Detail

readConfiguration

protected void readConfiguration(Map<String,String> configuration)
Read configuration settings

Overrides:
readConfiguration in class ClusterManager
Parameters:
configuration - read from config resource
Since:
MMBase-1.8.1

startCommunicationThreads

protected void startCommunicationThreads()
Description copied from class: ClusterManager
Subclasses should start the communication threads in this method

Specified by:
startCommunicationThreads in class ClusterManager

stopCommunicationThreads

protected void stopCommunicationThreads()
Description copied from class: ClusterManager
Subclasses should stop the communication threads in this method

Specified by:
stopCommunicationThreads in class ClusterManager

toString

public String toString()
Overrides:
toString in class Object


MMBase 2.0-SNAPSHOT - null