diff --git a/src/main/java/jenkins/plugins/logstash/LogstashConfiguration.java b/src/main/java/jenkins/plugins/logstash/LogstashConfiguration.java index 462d9177..2b1688b4 100644 --- a/src/main/java/jenkins/plugins/logstash/LogstashConfiguration.java +++ b/src/main/java/jenkins/plugins/logstash/LogstashConfiguration.java @@ -1,5 +1,6 @@ package jenkins.plugins.logstash; +import java.lang.Object; import java.net.URI; import java.net.URISyntaxException; import java.util.List; @@ -28,6 +29,7 @@ import jenkins.plugins.logstash.configuration.Syslog; import jenkins.plugins.logstash.persistence.LogstashIndexerDao; import jenkins.plugins.logstash.persistence.LogstashIndexerDao.IndexerType; +import jenkins.util.JenkinsJVM; import net.sf.json.JSONObject; @Extension diff --git a/src/main/java/jenkins/plugins/logstash/LogstashWriter.java b/src/main/java/jenkins/plugins/logstash/LogstashWriter.java index aad77e3a..5febaa80 100644 --- a/src/main/java/jenkins/plugins/logstash/LogstashWriter.java +++ b/src/main/java/jenkins/plugins/logstash/LogstashWriter.java @@ -159,6 +159,10 @@ public boolean isConnectionBroken() { // Method to encapsulate calls for unit-testing LogstashIndexerDao getIndexerDao() { + if (!JenkinsJVM.isJenkinsJVM()){ + return null; + } + return LogstashConfiguration.getInstance().getIndexerInstance(); }