Update of /var/cvs/applications/clustering/src/org/mmbase/clustering/unicast
In directory james.mmbase.org:/tmp/cvs-serv21137/unicast
Modified Files:
Tag: MMBase-1_8
Unicast.java
Log Message:
MMB-1691
See also:
http://cvs.mmbase.org/viewcvs/applications/clustering/src/org/mmbase/clustering/unicast
See also: http://www.mmbase.org/jira/browse/MMB-1691
Index: Unicast.java
===================================================================
RCS file:
/var/cvs/applications/clustering/src/org/mmbase/clustering/unicast/Unicast.java,v
retrieving revision 1.9
retrieving revision 1.9.2.1
diff -u -b -r1.9 -r1.9.2.1
--- Unicast.java 21 Jun 2006 05:46:20 -0000 1.9
+++ Unicast.java 22 Jul 2008 15:04:08 -0000 1.9.2.1
@@ -22,7 +22,7 @@
* @javadoc
*
* @author Nico Klasens
- * @version $Id: Unicast.java,v 1.9 2006/06/21 05:46:20 michiel Exp $
+ * @version $Id: Unicast.java,v 1.9.2.1 2008/07/22 15:04:08 michiel Exp $
*/
public class Unicast extends ClusterManager {
@@ -95,6 +95,9 @@
* @see org.mmbase.clustering.ClusterManager#startCommunicationThreads()
*/
protected synchronized void startCommunicationThreads() {
+ if (unicastPort == -1) {
+ log.service("Not starting multicast threads because port number
configured to be -1");
+ } else {
ucs = new ChangesSender(reader.getProperties(), unicastPort,
unicastTimeout, nodesToSend, send);
try {
ucr = new ChangesReceiver(unicastPort, nodesToSpawn);
@@ -102,6 +105,7 @@
log.error(ioe);
}
}
+ }
/**
* @see org.mmbase.clustering.ClusterManager#stopCommunicationThreads()
@@ -121,6 +125,7 @@
// javadoc inherited
public void changedNode(NodeEvent event) {
+ try {
byte[] message = createMessage(event);
nodesToSend.append(message);
//Multicast receives his own message. Unicast now too.
@@ -128,6 +133,9 @@
if (log.isDebugEnabled()) {
log.debug("message: " + event);
}
+ } catch (java.io.IOException ioe) {
+ log.warn(ioe);
+ }
return;
}
_______________________________________________
Cvs mailing list
[email protected]
http://lists.mmbase.org/mailman/listinfo/cvs
