org.mmbase.clustering.unicast
Class Unicast

java.lang.Object
  org.mmbase.clustering.ClusterManager
      org.mmbase.clustering.unicast.Unicast

All Implemented Interfaces:

Runnable, AllEventListener, EventListener

public class Unicast
extends ClusterManager

Unicast implementation for the mmbase cluster. This implemenetation opens a direct network connection to each host mentioned in the mmservers as active.

Version:

$Id: Unicast.java 42990 2010-07-23 16:20:59Z michiel $

Author:

Nico Klasens

Field Summary

static String

CONFIG_FILE

Fields inherited from class org.mmbase.clustering.ClusterManager

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

Constructor Summary

Unicast()

Method Summary

protected void	readConfiguration(Map<String,String> configuration)
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

Unicast

public Unicast()

Method Detail

readConfiguration

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

Overrides:

readConfiguration in class ClusterManager

startCommunicationThreads

protected void startCommunicationThreads()

Description copied from class: ClusterManager

Subclasses should start the communication threads in this method

Specified by:

startCommunicationThreads in class ClusterManager

See Also:

ClusterManager.startCommunicationThreads()

stopCommunicationThreads

protected void stopCommunicationThreads()

Description copied from class: ClusterManager

Subclasses should stop the communication threads in this method

Specified by:

stopCommunicationThreads in class ClusterManager

See Also:

ClusterManager.stopCommunicationThreads()

toString

public String toString()

Overrides:

toString in class Object