org.mmbase.module.core
Class MMBaseMultiCast
java.lang.Object
|
+--org.mmbase.module.core.MMBaseMultiCast
- All Implemented Interfaces:
- MMBaseChangeInterface, java.lang.Runnable
- public class MMBaseMultiCast
- extends java.lang.Object
- implements MMBaseChangeInterface, java.lang.Runnable
Builds a MultiCast Thread to receive and send
changes from other MMBase Servers.
- Version:
- $Revision: 1.12 $ $Date: 2001/05/04 13:48:52 $
- Author:
- Daniel Ockeloen, Rico Jansen
|
Method Summary |
boolean |
changedNode(int nodenr,
java.lang.String tableName,
java.lang.String type)
|
void |
checkWaitingNodes(java.lang.String snumber)
|
boolean |
commitXML(java.lang.String machine,
java.lang.String vnr,
java.lang.String id,
java.lang.String tb,
java.lang.String ctype,
java.lang.String xml)
|
void |
doWork()
admin probe, try's to make a call to all the maintainance calls. |
boolean |
handleMsg(java.lang.String machine,
java.lang.String vnr,
java.lang.String id,
java.lang.String tb,
java.lang.String ctype)
|
void |
init()
|
void |
run()
admin probe, try's to make a call to all the maintainance calls. |
void |
start()
Starts the admin Thread. |
void |
stop()
Stops the admin Thread. |
boolean |
waitUntilNodeChanged(MMObjectNode node)
|
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
incount
public int incount
outcount
public int outcount
spawncount
public int spawncount
multicastaddress
public static java.lang.String multicastaddress
dpsize
public static int dpsize
mport
public static int mport
MMBaseMultiCast
public MMBaseMultiCast(MMBase parent)
init
public void init()
start
public void start()
- Starts the admin Thread.
stop
public void stop()
- Stops the admin Thread.
run
public void run()
- admin probe, try's to make a call to all the maintainance calls.
- Specified by:
run in interface java.lang.Runnable
doWork
public void doWork()
- admin probe, try's to make a call to all the maintainance calls.
handleMsg
public boolean handleMsg(java.lang.String machine,
java.lang.String vnr,
java.lang.String id,
java.lang.String tb,
java.lang.String ctype)
- Specified by:
handleMsg in interface MMBaseChangeInterface
changedNode
public boolean changedNode(int nodenr,
java.lang.String tableName,
java.lang.String type)
- Specified by:
changedNode in interface MMBaseChangeInterface
waitUntilNodeChanged
public boolean waitUntilNodeChanged(MMObjectNode node)
- Specified by:
waitUntilNodeChanged in interface MMBaseChangeInterface
checkWaitingNodes
public void checkWaitingNodes(java.lang.String snumber)
- Specified by:
checkWaitingNodes in interface MMBaseChangeInterface
commitXML
public boolean commitXML(java.lang.String machine,
java.lang.String vnr,
java.lang.String id,
java.lang.String tb,
java.lang.String ctype,
java.lang.String xml)
- Specified by:
commitXML in interface MMBaseChangeInterface
MMBase 2002