diff options
Diffstat (limited to 'java/demo/Ice/bidir/CallbackSenderI.java')
| -rwxr-xr-x | java/demo/Ice/bidir/CallbackSenderI.java | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/java/demo/Ice/bidir/CallbackSenderI.java b/java/demo/Ice/bidir/CallbackSenderI.java index e0571088893..dfa01811ecb 100755 --- a/java/demo/Ice/bidir/CallbackSenderI.java +++ b/java/demo/Ice/bidir/CallbackSenderI.java @@ -11,6 +11,11 @@ import Demo.*; class CallbackSenderI extends _CallbackSenderDisp implements java.lang.Runnable { + CallbackSenderI(Ice.Communicator communicator) + { + _communicator = communicator; + } + synchronized public void destroy() { @@ -23,7 +28,7 @@ class CallbackSenderI extends _CallbackSenderDisp implements java.lang.Runnable synchronized public void addClient(Ice.Identity ident, Ice.Current current) { - System.out.println("adding client `" + Ice.Util.identityToString(ident) + "'"); + System.out.println("adding client `" + _communicator.identityToString(ident) + "'"); Ice.ObjectPrx base = current.con.createProxy(ident); CallbackReceiverPrx client = CallbackReceiverPrxHelper.uncheckedCast(base); @@ -57,7 +62,7 @@ class CallbackSenderI extends _CallbackSenderDisp implements java.lang.Runnable } catch(Exception ex) { - System.out.println("removing client `" + Ice.Util.identityToString(r.ice_getIdentity()) + "':"); + System.out.println("removing client `" + _communicator.identityToString(r.ice_getIdentity()) + "':"); ex.printStackTrace(); p.remove(); } @@ -66,6 +71,7 @@ class CallbackSenderI extends _CallbackSenderDisp implements java.lang.Runnable } } + private Ice.Communicator _communicator; private boolean _destroy = false; private int _num = 0; private java.util.Vector _clients = new java.util.Vector(); |