org.mmbase.clustering.multicast
Class ChangesReceiver

java.lang.Object
  extended by org.mmbase.clustering.multicast.ChangesReceiver
All Implemented Interfaces:
Runnable

public class ChangesReceiver
extends Object
implements Runnable

ChangesReceiver is a thread object that builds a MultiCast Thread to receive changes from other MMBase Servers.

Version:
$Id: ChangesReceiver.java 43064 2010-08-06 11:31:28Z michiel $
Author:
Daniel Ockeloen, Rico Jansen, Nico Klasens

Constructor Summary
ChangesReceiver(String multicastHost, int mport, int dpsize, BlockingQueue<byte[]> nodesToSpawn)
          Construct the MultiCast Receiver
 
Method Summary
 void run()
           
 void start()
           
(package private)  void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ChangesReceiver

public ChangesReceiver(String multicastHost,
                       int mport,
                       int dpsize,
                       BlockingQueue<byte[]> nodesToSpawn)
                throws UnknownHostException
Construct the MultiCast Receiver

Parameters:
multicastHost - 'channel' of the multicast
mport - port of the multicast
dpsize - datapacket receive size
nodesToSpawn - Queue of received messages
Throws:
UnknownHostException - when multicastHost is not found
Method Detail

start

public void start()

stop

void stop()

run

public void run()
Specified by:
run in interface Runnable


MMBase 2.0-SNAPSHOT - null