diff options
author | Bernard Normier <bernard@zeroc.com> | 2007-02-01 17:09:49 +0000 |
---|---|---|
committer | Bernard Normier <bernard@zeroc.com> | 2007-02-01 17:09:49 +0000 |
commit | abada90e3f84dc703b8ddc9efcbed8a946fadead (patch) | |
tree | 2c6f9dccd510ea97cb927a7bd635422efaae547a /java/demo/Ice/bidir/CallbackSenderI.java | |
parent | removing trace message (diff) | |
download | ice-abada90e3f84dc703b8ddc9efcbed8a946fadead.tar.bz2 ice-abada90e3f84dc703b8ddc9efcbed8a946fadead.tar.xz ice-abada90e3f84dc703b8ddc9efcbed8a946fadead.zip |
Expanded tabs into spaces
Diffstat (limited to 'java/demo/Ice/bidir/CallbackSenderI.java')
-rwxr-xr-x | java/demo/Ice/bidir/CallbackSenderI.java | 72 |
1 files changed, 36 insertions, 36 deletions
diff --git a/java/demo/Ice/bidir/CallbackSenderI.java b/java/demo/Ice/bidir/CallbackSenderI.java index 71a8745f900..05805692ca7 100755 --- a/java/demo/Ice/bidir/CallbackSenderI.java +++ b/java/demo/Ice/bidir/CallbackSenderI.java @@ -19,56 +19,56 @@ class CallbackSenderI extends _CallbackSenderDisp implements java.lang.Runnable synchronized public void destroy() { - System.out.println("destroying callback sender"); - _destroy = true; + System.out.println("destroying callback sender"); + _destroy = true; - this.notify(); + this.notify(); } synchronized public void addClient(Ice.Identity ident, Ice.Current current) { - System.out.println("adding client `" + _communicator.identityToString(ident) + "'"); + System.out.println("adding client `" + _communicator.identityToString(ident) + "'"); - Ice.ObjectPrx base = current.con.createProxy(ident); - CallbackReceiverPrx client = CallbackReceiverPrxHelper.uncheckedCast(base); - _clients.addElement(client); + Ice.ObjectPrx base = current.con.createProxy(ident); + CallbackReceiverPrx client = CallbackReceiverPrxHelper.uncheckedCast(base); + _clients.addElement(client); } synchronized public void run() { - while(!_destroy) - { - try - { - this.wait(2000); - } - catch(java.lang.InterruptedException ex) - { - } + while(!_destroy) + { + try + { + this.wait(2000); + } + catch(java.lang.InterruptedException ex) + { + } - if(!_destroy && !_clients.isEmpty()) - { - ++_num; + if(!_destroy && !_clients.isEmpty()) + { + ++_num; - java.util.Iterator p = _clients.iterator(); - while(p.hasNext()) - { - CallbackReceiverPrx r = (CallbackReceiverPrx)p.next(); - try - { - r.callback(_num); - } - catch(Exception ex) - { - System.out.println("removing client `" + _communicator.identityToString(r.ice_getIdentity()) + "':"); - ex.printStackTrace(); - p.remove(); - } - } - } - } + java.util.Iterator p = _clients.iterator(); + while(p.hasNext()) + { + CallbackReceiverPrx r = (CallbackReceiverPrx)p.next(); + try + { + r.callback(_num); + } + catch(Exception ex) + { + System.out.println("removing client `" + _communicator.identityToString(r.ice_getIdentity()) + "':"); + ex.printStackTrace(); + p.remove(); + } + } + } + } } private Ice.Communicator _communicator; |