summaryrefslogtreecommitdiff
path: root/java/demo/Ice/callback/Client.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/demo/Ice/callback/Client.java')
-rw-r--r--java/demo/Ice/callback/Client.java23
1 files changed, 23 insertions, 0 deletions
diff --git a/java/demo/Ice/callback/Client.java b/java/demo/Ice/callback/Client.java
index 35a91f8b6ac..f382f6cbf66 100644
--- a/java/demo/Ice/callback/Client.java
+++ b/java/demo/Ice/callback/Client.java
@@ -11,6 +11,22 @@ import Demo.*;
public class Client extends Ice.Application
{
+ class ShutdownHook extends Thread
+ {
+ public void
+ run()
+ {
+ try
+ {
+ communicator().destroy();
+ }
+ catch(Ice.LocalException ex)
+ {
+ ex.printStackTrace();
+ }
+ }
+ }
+
private static void
menu()
{
@@ -31,6 +47,13 @@ public class Client extends Ice.Application
public int
run(String[] args)
{
+ //
+ // Since this is an interactive demo we want to clear the
+ // Application installed interrupt callback and install our
+ // own shutdown hook.
+ //
+ setInterruptHook(new ShutdownHook());
+
CallbackSenderPrx twoway = CallbackSenderPrxHelper.checkedCast(
communicator().propertyToProxy("Callback.Client.CallbackServer").
ice_twoway().ice_timeout(-1).ice_secure(false));