diff options
Diffstat (limited to 'src/Ivy.java')
| -rwxr-xr-x | src/Ivy.java | 17 |
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 |