Update of /var/cvs/applications/clustering/src/org/mmbase/clustering
In directory
james.mmbase.org:/tmp/cvs-serv2657/applications/clustering/src/org/mmbase/clustering
Modified Files:
ClusterManager.java
Log Message:
mmbase unicast host configurable
Added javadoc
See also:
http://cvs.mmbase.org/viewcvs/applications/clustering/src/org/mmbase/clustering
Index: ClusterManager.java
===================================================================
RCS file:
/var/cvs/applications/clustering/src/org/mmbase/clustering/ClusterManager.java,v
retrieving revision 1.36
retrieving revision 1.37
diff -u -b -r1.36 -r1.37
--- ClusterManager.java 12 Dec 2007 16:19:52 -0000 1.36
+++ ClusterManager.java 9 May 2008 11:33:54 -0000 1.37
@@ -29,7 +29,7 @@
* @author Nico Klasens
* @author Michiel Meeuwissen
* @author Ernst Bunders
- * @version $Id: ClusterManager.java,v 1.36 2007/12/12 16:19:52 michiel Exp $
+ * @version $Id: ClusterManager.java,v 1.37 2008/05/09 11:33:54 nklasens Exp $
*/
public abstract class ClusterManager implements AllEventListener, Runnable {
@@ -158,6 +158,7 @@
/** Followup number of message */
protected int follownr = 1;
+ protected int lastRecievedMessage;
/**
* Creates MMBase 1.7 parseable message. This is simple String, which is
prefixed before the actual 1.8 message.
@@ -221,7 +222,13 @@
if (tok.hasMoreTokens()) {
String machine = tok.nextToken();
if (tok.hasMoreTokens()) {
- String vnr = tok.nextToken();
+ String fnr = tok.nextToken();
+ int newFollowNr = Integer.valueOf(fnr);
+ int expectedFollowNr = lastRecievedMessage + 1;
+ if (newFollowNr != expectedFollowNr) {
+ log.info("Expected message " + expectedFollowNr + ", but
message " + newFollowNr + " was recieved ");
+ }
+ lastRecievedMessage = newFollowNr;
if (tok.hasMoreTokens()) {
String id = tok.nextToken();
if (tok.hasMoreTokens()) {
_______________________________________________
Cvs mailing list
[email protected]
http://lists.mmbase.org/mailman/listinfo/cvs
