Shutdown hook logic

Release connections and partitions owned by this server instance

Change-Id: I293705b0d212fcba7e6f80678dee70130a8abe25
Issue-ID: MUSIC-361
Signed-off-by: Tschaen, Brendan <ctschaen@att.com>

diff --git a/mdbc-server/src/main/java/org/onap/music/mdbc/MdbcServer.java b/mdbc-server/src/main/java/org/onap/music/mdbc/MdbcServer.java
index 08f6e1e..1712c30 100755 (executable)
--- a/mdbc-server/src/main/java/org/onap/music/mdbc/MdbcServer.java
+++ b/mdbc-server/src/main/java/org/onap/music/mdbc/MdbcServer.java
@@ -103,6 +103,7 @@ public class MdbcServer {
 
   public void stop() {
          if (null != server) {
+             meta.getStateManager().releaseAllPartitions();
                  server.stop();
                  server = null;
          }

diff --git a/mdbc-server/src/main/java/org/onap/music/mdbc/StateManager.java b/mdbc-server/src/main/java/org/onap/music/mdbc/StateManager.java
index 8e7976f..430e783 100644 (file)
--- a/mdbc-server/src/main/java/org/onap/music/mdbc/StateManager.java
+++ b/mdbc-server/src/main/java/org/onap/music/mdbc/StateManager.java
@@ -344,4 +344,13 @@ public class StateManager {
     public OwnershipAndCheckpoint getOwnAndCheck() {
         return ownAndCheck;
     }
+
+    /**
+     * Close all connections for this server, relinquishing any locks/partitions owned by this server
+     */
+    public void releaseAllPartitions() {
+        for(String connection: this.connectionRanges.keySet()) {
+            closeConnection(connection);
+        } 
+    }
 }