diff options
author | jestin | 2012-08-23 19:39:32 +0000 |
---|---|---|
committer | jestin | 2012-08-23 19:39:32 +0000 |
commit | e3b0fb9534d783d62245be8d7777f35d34e6d59d (patch) | |
tree | 1216b70c18c478eb1e132c749b4ce4c09ae1b786 /tests/AsyncAPI.java | |
parent | e854a58a81ec90e419a4b3effa5a83caac05df90 (diff) | |
download | ivy-java-e3b0fb9534d783d62245be8d7777f35d34e6d59d.zip ivy-java-e3b0fb9534d783d62245be8d7777f35d34e6d59d.tar.gz ivy-java-e3b0fb9534d783d62245be8d7777f35d34e6d59d.tar.bz2 ivy-java-e3b0fb9534d783d62245be8d7777f35d34e6d59d.tar.xz |
Diffstat (limited to 'tests/AsyncAPI.java')
-rw-r--r-- | tests/AsyncAPI.java | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/tests/AsyncAPI.java b/tests/AsyncAPI.java index e174929..1f07565 100644 --- a/tests/AsyncAPI.java +++ b/tests/AsyncAPI.java @@ -43,8 +43,7 @@ class AsyncAPI { public AsyncAPI(int nb,String domain,int d, boolean v,boolean async) throws IvyException { verbose=v; nbpacket=nb; - name = "MSreceive"; - bus = new Ivy(name,null, null); + bus = new Ivy(RECEIVENAME,null, null); wait = d; delay=new DelayAnswer(); if (async) re = bus.bindAsyncMsg(TOSUBSCRIBE,delay,BindType.ASYNC); @@ -59,7 +58,7 @@ class AsyncAPI { static Object truc = new Object(); - int count=0,total=0; + volatile int count=0,total=0; int status = 0; synchronized void huh(IvyClient ic, String[] args) { @@ -95,7 +94,7 @@ class AsyncAPI { Thread.sleep(wait); System.out.println("RECEIVE Finished Sleeping"); } catch (InterruptedException ie) { - ie.printStackTrace(); + System.out.println("RECEIVE Sleeping interrupted, not a problem"); } } } |