public class ChangesSender extends Object implements Runnable
Multicast,
ChangesReceiver| Constructor and Description |
|---|
ChangesSender(org.jgroups.JChannel channel,
BlockingQueue<byte[]> nodesToSend,
Statistics send)
Construct MultiCast Sender
|
| Modifier and Type | Method and Description |
|---|---|
void |
run()
Take messages fromt the queeu nodesToSend and send them
on the JChannel.
|
(package private) void |
stop() |
ChangesSender(org.jgroups.JChannel channel,
BlockingQueue<byte[]> nodesToSend,
Statistics send)
channel - Channel on which to send messagesnodesToSend - Queue of messages to sendsend - StatisticsMMBase 1.9-SNAPSHOT - ${javadoctimestamp}