honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-17 18:35:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' of https://github.com/elasticsearch/elasticsearch-alerts

Browse Source 
Original commit: elastic/x-pack-elasticsearch@d91926ebdf
This commit is contained in:
Brian Murphy 2014-11-05 17:50:54 +00:00
commit 5d52c374b3
4 changed files with 74 additions and 53 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

116
pom.xml
View File

@ -14,12 +14,57 @@
<packaging>jar</packaging> <packaging>jar</packaging>
<properties> <properties>
<elasticsearch.version>1.4.0.Beta1</elasticsearch.version> <elasticsearch.version>1.4.0</elasticsearch.version>
<lucene.version>4.10.1</lucene.version> <lucene.version>4.10.2</lucene.version>
</properties> </properties>
<dependencies> <dependencies>
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.2.1</version>
</dependency>
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz-jobs</artifactId>
<version>2.2.1</version>
</dependency>
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.16</version>
</dependency>
<!-- Otherwise we can't see quartz logging -->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.7</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>1.7.7</version>
</dependency>
<dependency>
<groupId>javax.mail</groupId>
<artifactId>mail</artifactId>
<version>1.4.4</version>
</dependency>
<dependency>
<groupId>javax.activation</groupId>
<artifactId>activation</artifactId>
<version>1.1.1</version>
</dependency>
<!-- Test dependencies -->
<dependency> <dependency>
<groupId>org.apache.lucene</groupId> <groupId>org.apache.lucene</groupId>
<artifactId>lucene-test-framework</artifactId> <artifactId>lucene-test-framework</artifactId>
@ -33,6 +78,7 @@
<version>1.3.RC2</version> <version>1.3.RC2</version>
<scope>test</scope> <scope>test</scope>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.hamcrest</groupId> <groupId>org.hamcrest</groupId>
<artifactId>hamcrest-library</artifactId> <artifactId>hamcrest-library</artifactId>
@ -41,16 +87,10 @@
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.elasticsearch</groupId> <groupId>com.carrotsearch.randomizedtesting</groupId>
<artifactId>elasticsearch</artifactId> <artifactId>randomizedtesting-runner</artifactId>
<version>${elasticsearch.version}</version> <version>2.1.10</version>
<scope>provided</scope> <scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.lucene</groupId>
<artifactId>lucene-core</artifactId>
<version>${lucene.version}</version>
<scope>provided</scope>
</dependency> </dependency>
<dependency> <dependency>
@ -61,6 +101,22 @@
<scope>test</scope> <scope>test</scope>
</dependency> </dependency>
<!-- Provided dependencies -->
<dependency>
<groupId>org.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
<version>${elasticsearch.version}</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.apache.lucene</groupId>
<artifactId>lucene-core</artifactId>
<version>${lucene.version}</version>
<scope>provided</scope>
</dependency>
<dependency> <dependency>
<groupId>org.codehaus.groovy</groupId> <groupId>org.codehaus.groovy</groupId>
<artifactId>groovy-all</artifactId> <artifactId>groovy-all</artifactId>
@ -68,42 +124,6 @@
<scope>provided</scope> <scope>provided</scope>
</dependency> </dependency>
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.2.1</version>
</dependency>
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz-jobs</artifactId>
<version>2.2.1</version>
</dependency>
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.16</version>
</dependency>
<!-- Otherwise we can't see quartz logging -->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.7</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>1.7.7</version>
</dependency>
<dependency>
<groupId>javax.mail</groupId>
<artifactId>mail</artifactId>
<version>1.4.4</version>
</dependency>
<dependency>
<groupId>javax.activation</groupId>
<artifactId>activation</artifactId>
<version>1.1.1</version>
</dependency>
</dependencies> </dependencies>
<repositories> <repositories>
<repository> <repository>

2
src/main/java/org/elasticsearch/alerts/AlertManager.java
View File

@ -138,7 +138,7 @@ public class AlertManager extends AbstractComponent {
} }
public void stop() { public void stop() {
if (started.compareAndSet(false, true)) { if (started.compareAndSet(true, false)) {
scheduler.stop(); scheduler.stop();
alertsStore.stop(); alertsStore.stop();
actionManager.stop(); actionManager.stop();

3
src/main/java/org/elasticsearch/alerts/actions/AlertActionManager.java
View File

@ -16,6 +16,7 @@ import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.alerts.Alert; import org.elasticsearch.alerts.Alert;
import org.elasticsearch.alerts.AlertsStore; import org.elasticsearch.alerts.AlertsStore;
import org.elasticsearch.alerts.LoadingListener; import org.elasticsearch.alerts.LoadingListener;
import org.elasticsearch.alerts.plugin.AlertsPlugin;
import org.elasticsearch.alerts.triggers.TriggerManager; import org.elasticsearch.alerts.triggers.TriggerManager;
import org.elasticsearch.alerts.triggers.TriggerResult; import org.elasticsearch.alerts.triggers.TriggerResult;
import org.elasticsearch.client.Client; import org.elasticsearch.client.Client;
@ -123,7 +124,7 @@ public class AlertActionManager extends AbstractComponent {
logger.debug("Stopping thread to read from the job queue"); logger.debug("Stopping thread to read from the job queue");
return; return;
} }
threadPool.executor(ThreadPool.Names.MANAGEMENT).execute(new AlertHistoryRunnable(entry)); threadPool.executor(AlertsPlugin.THREAD_POOL_NAME).execute(new AlertHistoryRunnable(entry));
} }
} catch (Throwable t) { } catch (Throwable t) {
logger.error("Error during reader thread", t); logger.error("Error during reader thread", t);

6
src/main/java/org/elasticsearch/alerts/plugin/AlertsPlugin.java
View File

@ -17,10 +17,10 @@ import static org.elasticsearch.common.settings.ImmutableSettings.settingsBuilde
public class AlertsPlugin extends AbstractPlugin { public class AlertsPlugin extends AbstractPlugin {
public static final String NAME = "alerts"; public static final String THREAD_POOL_NAME = "alerts";
@Override public String name() { @Override public String name() {
return NAME; return THREAD_POOL_NAME;
} }
@Override public String description() { @Override public String description() {
@ -37,7 +37,7 @@ public class AlertsPlugin extends AbstractPlugin {
@Override @Override
public Settings additionalSettings() { public Settings additionalSettings() {
return settingsBuilder() return settingsBuilder()
.put("threadpool."+ NAME + ".type","cached") .put("threadpool."+ THREAD_POOL_NAME + ".type","cached")
.build(); .build();
} }