|
|
@ -1061,14 +1061,14 @@ public final class plasmaSwitchboard extends serverAbstractSwitch<IndexingStack.
|
|
|
|
log.logConfig("SWITCHBOARD SHUTDOWN STEP 2: sending termination signal to threaded indexing");
|
|
|
|
log.logConfig("SWITCHBOARD SHUTDOWN STEP 2: sending termination signal to threaded indexing");
|
|
|
|
// closing all still running db importer jobs
|
|
|
|
// closing all still running db importer jobs
|
|
|
|
indexingDocumentProcessor.announceShutdown();
|
|
|
|
indexingDocumentProcessor.announceShutdown();
|
|
|
|
indexingDocumentProcessor.awaitShutdown(4000);
|
|
|
|
indexingDocumentProcessor.awaitShutdown(12000);
|
|
|
|
crawlStacker.announceClose();
|
|
|
|
crawlStacker.announceClose();
|
|
|
|
indexingCondensementProcessor.announceShutdown();
|
|
|
|
indexingCondensementProcessor.announceShutdown();
|
|
|
|
indexingAnalysisProcessor.announceShutdown();
|
|
|
|
indexingAnalysisProcessor.announceShutdown();
|
|
|
|
indexingStorageProcessor.announceShutdown();
|
|
|
|
indexingStorageProcessor.announceShutdown();
|
|
|
|
indexingCondensementProcessor.awaitShutdown(3000);
|
|
|
|
indexingCondensementProcessor.awaitShutdown(12000);
|
|
|
|
indexingAnalysisProcessor.awaitShutdown(2000);
|
|
|
|
indexingAnalysisProcessor.awaitShutdown(12000);
|
|
|
|
indexingStorageProcessor.awaitShutdown(1000);
|
|
|
|
indexingStorageProcessor.awaitShutdown(12000);
|
|
|
|
crawlStacker.close();
|
|
|
|
crawlStacker.close();
|
|
|
|
this.dbImportManager.close();
|
|
|
|
this.dbImportManager.close();
|
|
|
|
JakartaCommonsHttpClient.closeAllConnections();
|
|
|
|
JakartaCommonsHttpClient.closeAllConnections();
|
|
|
|