configurable indexer

Author: schlotze

context-monitoring/src/main/java/de/atb/context/monitoring/monitors/ThreadedMonitor.java

@@ -101,6 +101,8 @@ protected ThreadedMonitor(final DataSource dataSource,
 
     public abstract void monitor() throws Exception;
 
+    protected abstract boolean isIndexEnabled();
+
     public final void stop() {
         // if (this.isRunning()) {
         this.shutdown();
@@ -160,8 +162,10 @@ protected final void parseAndAnalyse(final P objectToParse,
         if (parser.parse(objectToParse)) {
             final Document document = parser.getDocument();
             this.raiseParsedEvent(objectToParse, document);
-            this.indexer.addDocumentToIndex(document);
-            this.raiseIndexedEvent(document);
+            if (isIndexEnabled()) {
+                this.indexer.addDocumentToIndex(document);
+                this.raiseIndexedEvent(document);
+            }
             final List<A> analysedModels = analyser.analyse(objectToParse);
             this.raiseAnalysedEvent(analysedModels, objectToParse, analyser.getDocument());
         }

context-monitoring/src/main/java/de/atb/context/monitoring/monitors/database/DatabaseMonitor.java

@@ -69,6 +69,11 @@ protected InterpreterConfiguration getInterpreterConfiguration() {
         return this.interpreter.getConfiguration("monitoring-config.xml");
     }
 
+    @Override
+    protected boolean isIndexEnabled() {
+        return false;
+    }
+
     @Override
     protected void doMonitor(final InterpreterConfiguration setting) {
         if (setting != null) {

context-monitoring/src/main/java/de/atb/context/monitoring/monitors/file/AbstractFileSystemMonitor.java

@@ -88,6 +88,11 @@ public final void run() {
         }
     }
 
+    @Override
+    protected boolean isIndexEnabled() {
+        return true;
+    }
+
     @Override
     public final void monitor() throws Exception {
         this.logger.info("Starting monitoring for path " + this.pathToMonitor);

context-monitoring/src/main/java/de/atb/context/monitoring/monitors/messagebroker/MessageBrokerMonitor.java

@@ -77,6 +77,11 @@ protected InterpreterConfiguration getInterpreterConfiguration() {
         return this.interpreter.getConfigurations().isEmpty() ? null : this.interpreter.getConfigurations().get(0);
     }
 
+    @Override
+    protected boolean isIndexEnabled() {
+        return false;
+    }
+
     @Override
     protected void doMonitor(final InterpreterConfiguration setting) throws Exception {
         if (setting != null) {

context-monitoring/src/main/java/de/atb/context/monitoring/monitors/webservice/WebServiceMonitor.java

@@ -69,6 +69,11 @@ protected long getScheduleInitialDelay() {
         return this.dataSource.getStartDelay() != null ? this.dataSource.getStartDelay() : getSchedulePeriod();
     }
 
+    @Override
+    protected boolean isIndexEnabled() {
+        return false;
+    }
+
     @Override
     protected void doMonitor(final InterpreterConfiguration setting) {
         if (setting != null) {