aboutsummaryrefslogtreecommitdiff
path: root/src/Ivy.java
diff options
context:
space:
mode:
authorjestin2004-12-23 16:12:25 +0000
committerjestin2004-12-23 16:12:25 +0000
commitccaba8df37149f7e744ebf9ff6a1dc350a32942b (patch)
tree04ecb2aeab20dec5e3ed13419e4dc50390f2a316 /src/Ivy.java
parent031f955efd5fa20041f7344041f290b15b20c019 (diff)
downloadivy-java-ccaba8df37149f7e744ebf9ff6a1dc350a32942b.zip
ivy-java-ccaba8df37149f7e744ebf9ff6a1dc350a32942b.tar.gz
ivy-java-ccaba8df37149f7e744ebf9ff6a1dc350a32942b.tar.bz2
ivy-java-ccaba8df37149f7e744ebf9ff6a1dc350a32942b.tar.xz
preparing the 1.2.7 release
Diffstat (limited to 'src/Ivy.java')
-rwxr-xr-xsrc/Ivy.java17
1 files changed, 7 insertions, 10 deletions
diff --git a/src/Ivy.java b/src/Ivy.java
index 196c3b4..3236ba4 100755
--- a/src/Ivy.java
+++ b/src/Ivy.java
@@ -13,6 +13,8 @@
*</pre>
*
* CHANGELOG:
+ * 1.2.7:
+ * - minor fixes for accessing static final values
* 1.2.6:
* - added serial numbers for traceDebug
* - changed the semantic of -b a,b:port,c:otherport if no port is
@@ -93,11 +95,11 @@ public class Ivy implements Runnable {
* the library version, useful for development purposes only, when java is
* invoked with -DIVY_DEBUG
*/
- public static final String libVersion ="1.2.6";
+ public static final String libVersion ="1.2.7";
private boolean debug;
private ServerSocket app;
- private Vector watchers;
+ private Vector watchers = new Vector();
private volatile Thread serverThread; // to ensure quick communication of the end
private Hashtable clients = new Hashtable();
private Hashtable half = new Hashtable();
@@ -200,14 +202,11 @@ public class Ivy implements Runnable {
throw new IvyException("can't open TCP service socket " + e );
}
traceDebug("lib: "+libVersion+" protocol: "+PROTOCOLVERSION+" TCP service open on port "+applicationPort);
- watchers = new Vector();
Domain[] d = parseDomains(domainbus);
// readies the rendezvous : an IvyWatcher (thread) per domain bus
- for (int index=0;index<d.length;index++){
- IvyWatcher watcher =new IvyWatcher(this,d[index].domainaddr,d[index].port);
- watchers.addElement(watcher);
- }
+ for (int index=0;index<d.length;index++)
+ watchers.addElement(new IvyWatcher(this,d[index].domainaddr,d[index].port));
serverThread = new Thread(this);
serverThread.start();
// sends the broadcasts and listen to incoming connexions
@@ -403,9 +402,7 @@ public class Ivy implements Runnable {
* whenever an exception occured during unbinding
* @param String the string for the regular expression
*/
- public boolean unBindMsg(String re) {
- return selfIvyClient.unBindMsg(re);
- }
+ public boolean unBindMsg(String re) { return selfIvyClient.unBindMsg(re); }
/**
* adds a bind listener to a bus