Update of /var/cvs/applications/clustering/src/org/mmbase/clustering/multicast In directory james.mmbase.org:/tmp/cvs-serv2657/applications/clustering/src/org/mmbase/clustering/multicast
Modified Files: ChangesReceiver.java ChangesSender.java Multicast.java Log Message: mmbase unicast host configurable Added javadoc See also: http://cvs.mmbase.org/viewcvs/applications/clustering/src/org/mmbase/clustering/multicast Index: ChangesReceiver.java =================================================================== RCS file: /var/cvs/applications/clustering/src/org/mmbase/clustering/multicast/ChangesReceiver.java,v retrieving revision 1.15 retrieving revision 1.16 diff -u -b -r1.15 -r1.16 --- ChangesReceiver.java 21 Jun 2007 15:50:23 -0000 1.15 +++ ChangesReceiver.java 9 May 2008 11:33:54 -0000 1.16 @@ -23,7 +23,7 @@ * @author Daniel Ockeloen * @author Rico Jansen * @author Nico Klasens - * @version $Id: ChangesReceiver.java,v 1.15 2007/06/21 15:50:23 nklasens Exp $ + * @version $Id: ChangesReceiver.java,v 1.16 2008/05/09 11:33:54 nklasens Exp $ */ public class ChangesReceiver implements Runnable { @@ -53,6 +53,7 @@ * @param mport port of the multicast * @param dpsize datapacket receive size * @param nodesToSpawn Queue of received messages + * @throws UnknownHostException when multicastHost is not found */ ChangesReceiver(String multicastHost, int mport, int dpsize, BlockingQueue<byte[]> nodesToSpawn) throws UnknownHostException { this.mport = mport; Index: ChangesSender.java =================================================================== RCS file: /var/cvs/applications/clustering/src/org/mmbase/clustering/multicast/ChangesSender.java,v retrieving revision 1.15 retrieving revision 1.16 diff -u -b -r1.15 -r1.16 --- ChangesSender.java 12 Dec 2007 16:17:20 -0000 1.15 +++ ChangesSender.java 9 May 2008 11:33:54 -0000 1.16 @@ -26,7 +26,7 @@ * @author Daniel Ockeloen * @author Rico Jansen * @author Nico Klasens - * @version $Id: ChangesSender.java,v 1.15 2007/12/12 16:17:20 michiel Exp $ + * @version $Id: ChangesSender.java,v 1.16 2008/05/09 11:33:54 nklasens Exp $ */ public class ChangesSender implements Runnable { @@ -58,6 +58,7 @@ * @param mTTL time-to-live of the multicast packet (0-255) * @param nodesToSend Queue of messages to send * @param send Statistics object in which to administer duration costs + * @throws UnknownHostException when multicastHost is not found */ ChangesSender(String multicastHost, int mport, int mTTL, BlockingQueue<byte[]> nodesToSend, Statistics send) throws UnknownHostException { this.mport = mport; Index: Multicast.java =================================================================== RCS file: /var/cvs/applications/clustering/src/org/mmbase/clustering/multicast/Multicast.java,v retrieving revision 1.12 retrieving revision 1.13 diff -u -b -r1.12 -r1.13 --- Multicast.java 21 Jun 2007 15:50:23 -0000 1.12 +++ Multicast.java 9 May 2008 11:33:54 -0000 1.13 @@ -25,7 +25,7 @@ * @author Daniel Ockeloen * @author Rico Jansen * @author Nico Klasens - * @version $Id: Multicast.java,v 1.12 2007/06/21 15:50:23 nklasens Exp $ + * @version $Id: Multicast.java,v 1.13 2008/05/09 11:33:54 nklasens Exp $ */ public class Multicast extends ClusterManager { @@ -78,6 +78,8 @@ } /** + * Read configuration settings + * @param configuration read from config resource * @since MMBase-1.8.1 */ protected synchronized void readConfiguration(Map<String,String> configuration) { _______________________________________________ Cvs mailing list Cvs@lists.mmbase.org http://lists.mmbase.org/mailman/listinfo/cvs