svn commit: r1859274 - /jackrabbit/oak/trunk/oak-segment-azure/src/main/java/org/apache/jackrabbit/oak/segment/azure/tool/SegmentStoreMigrator.java

[tomekr]

Author: tomekr
Date: Wed May 15 08:25:09 2019
New Revision: 1859274

URL: http://svn.apache.org/viewvc?rev=1859274&view=rev
Log:
OAK-8318: Allow to close the SegmentStoreMigrator

Modified:
    
jackrabbit/oak/trunk/oak-segment-azure/src/main/java/org/apache/jackrabbit/oak/segment/azure/tool/SegmentStoreMigrator.java

Modified: 
jackrabbit/oak/trunk/oak-segment-azure/src/main/java/org/apache/jackrabbit/oak/segment/azure/tool/SegmentStoreMigrator.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-segment-azure/src/main/java/org/apache/jackrabbit/oak/segment/azure/tool/SegmentStoreMigrator.java?rev=1859274&r1=1859273&r2=1859274&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-segment-azure/src/main/java/org/apache/jackrabbit/oak/segment/azure/tool/SegmentStoreMigrator.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-segment-azure/src/main/java/org/apache/jackrabbit/oak/segment/azure/tool/SegmentStoreMigrator.java
 Wed May 15 08:25:09 2019
@@ -39,6 +39,7 @@ import org.apache.jackrabbit.oak.segment
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.io.Closeable;
 import java.io.File;
 import java.io.IOException;
 import java.net.URISyntaxException;
@@ -52,7 +53,7 @@ import java.util.concurrent.ExecutorServ
 import java.util.concurrent.Executors;
 import java.util.concurrent.Future;
 
-public class SegmentStoreMigrator {
+public class SegmentStoreMigrator implements Closeable  {
 
     private static final Logger log = 
LoggerFactory.getLogger(SegmentStoreMigrator.class);
 
@@ -178,6 +179,11 @@ public class SegmentStoreMigrator {
         }
     }
 
+    @Override
+    public void close() throws IOException {
+        executor.shutdown();
+    }
+
     private static class Segment {
 
         private final SegmentArchiveEntry entry;