cqframework
diff --git a/‎cqf-fhir-cr-hapi/src/main/java/org/opencds/cqf/fhir/cr/hapi/common/HapiCreateChangelogProcessor.java‎
Lines changed: 2 additions & 1 deletion b/‎cqf-fhir-cr-hapi/src/main/java/org/opencds/cqf/fhir/cr/hapi/common/HapiCreateChangelogProcessor.java‎
Lines changed: 2 additions & 1 deletion
@@ -83,11 +83,12 @@ public IBaseResource createChangelog(
             targetBundle = (Bundle) packages.get(1).get();
             service.shutdownNow();
         } catch (InterruptedException | ExecutionException e) {
-            service.shutdownNow();
             if (e instanceof InterruptedException) {
                 Thread.currentThread().interrupt();
             }
             throw new UnprocessableEntityException(e.getMessage());
+        } finally {
+            service.shutdown();
         }
 
         // 2) Fill the cache with the bundle contents
Original file line number	Diff line number	Diff line change
`@@ -83,11 +83,12 @@ public IBaseResource createChangelog(`
`83`	`83`	`targetBundle = (Bundle) packages.get(1).get();`
`84`	`84`	`service.shutdownNow();`
`85`	`85`	`} catch (InterruptedException \| ExecutionException e) {`
`86`		`- service.shutdownNow();`
`87`	`86`	`if (e instanceof InterruptedException) {`
`88`	`87`	`Thread.currentThread().interrupt();`
`89`	`88`	`}`
`90`	`89`	`throw new UnprocessableEntityException(e.getMessage());`
	`90`	`+ } finally {`
	`91`	`+ service.shutdown();`
`91`	`92`	`}`
`92`	`93`
`93`	`94`	`// 2) Fill the cache with the bundle contents`