org.mmbase.clustering.jgroups
Class ChangesSender

java.lang.Object
  org.mmbase.clustering.jgroups.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 the multicast 'channel'. This is the JGroups variant.

Version:

$Id: ChangesSender.java 35335 2009-05-21 08:14:41Z michiel $

Author:

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

See Also:

Multicast, ChangesReceiver

Constructor Summary

ChangesSender(org.jgroups.JChannel channel, BlockingQueue<byte[]> nodesToSend, Statistics send)
Construct MultiCast Sender

Method Summary

void	run() Take messages fromt the queeu nodesToSend and send them on the JChannel.
(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(org.jgroups.JChannel channel,
              BlockingQueue<byte[]> nodesToSend,
              Statistics send)

Construct MultiCast Sender

Parameters:

channel - Channel on which to send messages

nodesToSend - Queue of messages to send

send - Statistics

Method Detail

stop

void stop()

run

public void run()

Take messages fromt the queeu nodesToSend and send them on the JChannel. send() will throw an exception in the cases that the channel is closed or that no channel has been joined.

Specified by:

run in interface Runnable