org.mmbase.clustering.jgroups
Class Multicast

java.lang.Object
  org.mmbase.clustering.ClusterManager
      org.mmbase.clustering.jgroups.Multicast

All Implemented Interfaces:

AllEventListener, EventListener, Runnable

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. This is the version that uses JavaGroups (JGroups) to ensure reliable delivery of multicast messages. See http://www.jgroups.org/ for more information on JGroups.

Version:

$Id: Multicast.java,v 1.9 2006/07/06 11:40:48 michiel Exp $

Author:

Daniel Ockeloen, Rico Jansen, Nico Klasens, Costyn van Dongen, Ronald Wildenberg

See Also:

ChangesSender, ChangesReceiver

Field Summary

static String

CONFIG_FILE Field containing the configuration file with the various options that can be specified for configuring the JGroups channel

Fields inherited from class org.mmbase.clustering.ClusterManager

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

Constructor Summary

Multicast()

Method Summary

protected void	readConfiguration(Map configuration)
protected void	startCommunicationThreads() Starts the ChangesSender and MulticastChangerReciever threads, which handle the sending and recieving of messages on the channel in seaparate threads.
protected void	stopCommunicationThreads() Subclasses should stop the communication threads in this method

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, toString, wait, wait, wait

Field Detail

CONFIG_FILE

public static final String CONFIG_FILE

Field containing the configuration file with the various options that can be specified for configuring the JGroups channel

See Also:

Constant Field Values

Constructor Detail

Multicast

public Multicast()

Method Detail

readConfiguration

protected void readConfiguration(Map configuration)

Overrides:

readConfiguration in class ClusterManager

Since:

MMBase-1.8.1

startCommunicationThreads

protected void startCommunicationThreads()

Starts the ChangesSender and MulticastChangerReciever threads, which handle the sending and recieving of messages on the channel in seaparate threads.

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