org.mmbase.clustering.multicast

Class Multicast

java.lang.Object

org.mmbase.clustering.ClusterManager

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$

Author:

Daniel Ockeloen, Rico Jansen, Nico Klasens

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONFIG_FILE

Fields inherited from class org.mmbase.clustering.ClusterManager

compatible17, follownr, kicker, lastRecievedMessage, nodesToSend, nodesToSpawn, receive, send, spawnThreads

Constructor Summary

Constructors

Constructor and Description
Multicast()

Method Summary

Modifier and Type	Method and Description
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

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