#162: added property that allows to enable/disable a full index rebui…

…ld on startup.
redlink-gmbh · Dec 7, 2017 · 5c6921e · 5c6921e
1 parent beb2dd3
commit 5c6921e
Show file tree

Hide file tree

Showing 2 changed files with 22 additions and 14 deletions.
diff --git a/application/src/main/resources/application.properties b/application/src/main/resources/application.properties
@@ -45,6 +45,9 @@ endpoints.metrics.enabled=false
 #deactivate the interesting terms from previous conversations
 smarti.analysis.optional=*,!keyword.interestingterms.conversation
 
+#enable/disable full rebuild of indexes on startup (default: true)
+#smarti.indexing.rebuildOnStartup=true
+
 #rocketchat.proxy.hostname=127.0.0.1
 #rocketchat.proxy.port=8181
 #rocketchat.proxy.scheme=http

diff --git a/...-conversation/src/main/java/io/redlink/smarti/query/conversation/ConversationIndexer.java b/...-conversation/src/main/java/io/redlink/smarti/query/conversation/ConversationIndexer.java
@@ -137,6 +137,9 @@ public class ConversationIndexer implements ConversytionSyncCallback {
 
     private final ExecutorService indexerPool;
 
+    @Value("${smarti.indexing.rebuildOnStartup:true}")
+    private boolean rebuildOnStartup = true;
+
     @Autowired
     public ConversationIndexer(SolrCoreContainer solrServer, StoreService storeService){
         this.solrServer = solrServer;
@@ -161,21 +164,23 @@ protected void startup() {
         if(indexTask != null){
             log.info("initialize ConversationIndex after startup ...");
             Date syncDate = null;
-            try (SolrClient solr = solrServer.getSolrClient(conversationCore)){
-                //read (1) FIELD_SYNC_DATE from index 
-                SolrQuery query = new SolrQuery("*:*");
-                query.addSort(FIELD_SYNC_DATE, ORDER.desc);
-                query.setFields(FIELD_SYNC_DATE);
-                query.setRows(1);
-                query.setStart(0);
-                QueryResponse result = solr.query(query);
-                if(result.getResults() != null && result.getResults().getNumFound() > 0){
-                    syncDate = (Date)result.getResults().get(0).getFieldValue(FIELD_SYNC_DATE);
-                    log.debug("set lastSync date to {}", syncDate);
+            if(!rebuildOnStartup){
+                try (SolrClient solr = solrServer.getSolrClient(conversationCore)){
+                    //read (1) FIELD_SYNC_DATE from index 
+                    SolrQuery query = new SolrQuery("*:*");
+                    query.addSort(FIELD_SYNC_DATE, ORDER.desc);
+                    query.setFields(FIELD_SYNC_DATE);
+                    query.setRows(1);
+                    query.setStart(0);
+                    QueryResponse result = solr.query(query);
+                    if(result.getResults() != null && result.getResults().getNumFound() > 0){
+                        syncDate = (Date)result.getResults().get(0).getFieldValue(FIELD_SYNC_DATE);
+                        log.debug("set lastSync date to {}", syncDate);
+                    }
+                } catch (IOException | SolrServerException e) {
+                    log.warn("Updating Conversation index on startup failed ({} - {})", e.getClass().getSimpleName(), e.getMessage());
+                    log.debug("STACKTRACE:",e);
                 }
-            } catch (IOException | SolrServerException e) {
-                log.warn("Updating Conversation index on startup failed ({} - {})", e.getClass().getSimpleName(), e.getMessage());
-                log.debug("STACKTRACE:",e);
             }
             indexTask.setLastSync(syncDate);
             indexerPool.execute(indexTask);