(issue #29) producer cluster example with shutdown hook

questdb · Jan 22, 2015 · 29d9544 · 29d9544
1 parent 9b4e5fa
commit 29d9544
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/nfsdb-examples/src/main/java/org/nfsdb/examples/network/cluster/ClusteredProducerMain.java b/nfsdb-examples/src/main/java/org/nfsdb/examples/network/cluster/ClusteredProducerMain.java
@@ -18,6 +18,7 @@
 
 import com.nfsdb.JournalWriter;
 import com.nfsdb.exceptions.JournalException;
+import com.nfsdb.exceptions.JournalNetworkException;
 import com.nfsdb.factory.JournalFactory;
 import com.nfsdb.factory.configuration.JournalConfigurationBuilder;
 import com.nfsdb.net.cluster.ClusterController;
@@ -58,6 +59,17 @@ public static void main(String[] args) throws JournalException {
         );
 
         cc.start();
+
+        Runtime.getRuntime().addShutdownHook(new Thread() {
+            @Override
+            public void run() {
+                try {
+                    cc.halt();
+                } catch (JournalNetworkException e) {
+                    e.printStackTrace();
+                }
+            }
+        });
     }
 
     /**