diff options
| -rw-r--r-- | docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingHandler.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingHandler.java b/docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingHandler.java index 335fec8c5c0..d20836c4b59 100644 --- a/docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingHandler.java +++ b/docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingHandler.java @@ -121,7 +121,8 @@ public class DocumentProcessingHandler extends AbstractRequestHandler { @Override protected void destroy() { - //threadPoolMap.values().forEach( pool -> pool.shutdown()); //calling shutdownNow() seems like a bit of an overkill + laterExecutor.shutdown(); + docprocServiceRegistry.allComponents().forEach(docprocService -> docprocService.deconstruct()); } public ComponentRegistry<DocprocService> getDocprocServiceRegistry() { |