diff options
Diffstat (limited to 'docproc')
-rw-r--r-- | docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingHandler.java | 6 |
1 files changed, 5 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 e686fe6254f..73d72aabcb9 100644 --- a/docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingHandler.java +++ b/docproc/src/main/java/com/yahoo/docproc/jdisc/DocumentProcessingHandler.java @@ -116,7 +116,11 @@ public class DocumentProcessingHandler extends AbstractRequestHandler { @Override protected void destroy() { laterExecutor.shutdown(); - docprocServiceRegistry.allComponents().forEach(docprocService -> docprocService.deconstruct()); + if ( ! laterExecutor.getQueue().isEmpty()) { + // This should not happen, as container should keep this alive until all requests are served. + log.log(Level.SEVERE, "Docproc laterExecutor queue not empty on shutdown, " + laterExecutor.getQueue().size() + " tasks discarded"); + } + docprocServiceRegistry.allComponents().forEach(DocprocService::deconstruct); } public ComponentRegistry<DocprocService> getDocprocServiceRegistry() { |