org.mmbase.clustering.unicast

Class ChangesSender

java.lang.Object

org.mmbase.clustering.unicast.ChangesSender

All Implemented Interfaces:

Runnable

public class ChangesSender
extends Object
implements Runnable

ChangesSender is a thread object sending the nodes found in the sending queue over unicast connections

Version:

$Id$

Author:

Nico Klasens

Constructor Summary

Constructors

Constructor and Description
ChangesSender(Map<String,String> configuration, int unicastPort, int unicastTimeout, BlockingQueue<byte[]> nodesToSend, Statistics send) Construct UniCast Sender

Method Summary

Modifier and Type	Method and Description
void	run()
(package private) void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ChangesSender

ChangesSender(Map<String,String> configuration,
              int unicastPort,
              int unicastTimeout,
              BlockingQueue<byte[]> nodesToSend,
              Statistics send)

Construct UniCast Sender

Parameters:

configuration - configuration of unicast

unicastPort - port of the unicast connections

unicastTimeout - timeout on the connections

nodesToSend - Queue of messages to send

send - Statistics

Method Detail

stop

void stop()

run

public void run()

Specified by:

run in interface Runnable