add option ext_plugin_slack_object_alert_enabled

Author: gunlee01

README.md

@@ -24,8 +24,9 @@
 * **_ext\_plugin\_elapsed\_time\_threshold_** : 응답시간의 임계치 (ms) - 기본 값은 0으로, 0일때 응답시간의 임계치 초과 여부를 확인하지 않는다.
 * **_ext\_plugin\_gc\_time\_threshold_** : GC Time의 임계치 (ms) - 기본 값은 0으로, 0일때 GC Time의 임계치 초과 여부를 확인하지 않는다.
 * **_ext\_plugin\_thread\_count\_threshold_** : Thread Count의 임계치 - 기본 값은 0으로, 0일때 Thread Count의 임계치 초과 여부를 확인하지 않는다.
-* **_ext\_plugin\_slack\_xlog\_enabled_** : xlog maasege send (true / false) - default : false
-
+* **_ext\_plugin\_slack\_xlog\_enabled_** : xlog message send (true / false) - default : false
+* **_ext_plugin_slack_object_alert_enabled_** : object active/dead alert (true / false) - default : false
+  
 * Example
 ```
 # External Interface (Slack)
@@ -38,6 +39,7 @@ ext_plugin_slack_botName=scouter
 ext_plugin_slack_icon_emoji=:computer:
 ext_plugin_slack_icon_url=http://XXX.XXX.XXX/XXX.gif
 ext_plugin_slack_xlog_enabled=true
+ext_plugin_slack_object_alert_enabled=true
 
 ext_plugin_elapsed_time_threshold=5000
 ext_plugin_gc_time_threshold=5000

README_kr.md

@@ -25,6 +25,7 @@
 * **_ext\_plugin\_gc\_time\_threshold_** : GC Time의 임계치 (ms) - 기본 값은 0으로, 0일때 GC Time의 임계치 초과 여부를 확인하지 않는다.
 * **_ext\_plugin\_thread\_count\_threshold_** : Thread Count의 임계치 - 기본 값은 0으로, 0일때 Thread Count의 임계치 초과 여부를 확인하지 않는다.
 * **_ext\_plugin\_slack\_xlog\_enabled_** : xlog maasege send (true / false) - default : false
+* **_ext_plugin_slack_object_alert_enabled_** : object active/dead alert (true / false) - default : false
 
 * Example
 ```

pom.xml

@@ -23,7 +23,7 @@
 
     <groupId>com.github.scouter-project</groupId>
     <artifactId>scouter-plugin-server-alert-slack</artifactId>
-    <version>1.0.1-SNAPSHOT</version>
+    <version>1.1.0</version>
 
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

src/main/java/scouter/plugin/server/alert/slack/SlackPlugin.java

@@ -18,23 +18,14 @@
  */
 package scouter.plugin.server.alert.slack;
 
-import java.util.ArrayList;
-import java.util.List;
-import java.util.concurrent.Executors;
-import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicInteger;
-
+import com.google.gson.Gson;
 import org.apache.http.HttpResponse;
 import org.apache.http.HttpStatus;
 import org.apache.http.client.methods.HttpPost;
 import org.apache.http.entity.StringEntity;
 import org.apache.http.impl.client.CloseableHttpClient;
 import org.apache.http.impl.client.HttpClientBuilder;
 import org.apache.http.util.EntityUtils;
-
-import com.google.gson.Gson;
-
 import scouter.lang.AlertLevel;
 import scouter.lang.TextTypes;
 import scouter.lang.TimeTypeEnum;
@@ -56,6 +47,13 @@
 import scouter.util.DateUtil;
 import scouter.util.HashUtil;
 
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicInteger;
+
 /**
  * Scouter server plugin to send alert via Slack
  *
@@ -80,6 +78,9 @@ public SlackPlugin() {
 	    	executor.scheduleAtFixedRate(new Runnable() {
 				@Override
 				public void run() {
+					if (conf.getInt("ext_plugin_thread_count_threshold", 0) == 0) {
+						return;
+					}
 					for (int objHash : javaeeObjHashList) {
 						try {
 							if (AgentManager.isActive(objHash)) {
@@ -118,7 +119,6 @@ public void run() {
 	@ServerPlugin(PluginConstants.PLUGIN_SERVER_ALERT)
 	public void alert(final AlertPack pack){
 		if (groupConf.getBoolean("ext_plugin_slack_send_alert", pack.objType, false)) {
-
 			int level = groupConf.getInt("ext_plugin_slack_level", pack.objType, 0);
 			// Get log level (0 : INFO, 1 : WARN, 2 : ERROR, 3 : FATAL)
 			if(level <= pack.level){
@@ -200,6 +200,10 @@ public void run(){
 
 	@ServerPlugin(PluginConstants.PLUGIN_SERVER_OBJECT)
 	public void object(ObjectPack pack){
+		if (!conf.getBoolean("ext_plugin_slack_object_alert_enabled", false)) {
+			return;
+		}
+
 		if (pack.version != null && pack.version.length() > 0) {
 			AlertPack ap = null;
 			ObjectPack op = AgentManager.getAgent(pack.objHash);
@@ -238,10 +242,12 @@ public void object(ObjectPack pack){
 
 	@ServerPlugin(PluginConstants.PLUGIN_SERVER_XLOG)
 	public void xlog(XLogPack pack) {
-		
+		if (!conf.getBoolean("ext_plugin_slack_xlog_enabled", false)) {
+			return;
+		}
+
 		String objType = AgentManager.getAgent(pack.objHash).objType;
-		
-		if ( groupConf.getBoolean("ext_plugin_slack_xlog_enabled", objType, true)) {
+		if (groupConf.getBoolean("ext_plugin_slack_xlog_enabled", objType, true)) {
 			if (pack.error != 0) {
 				String date = DateUtil.yyyymmdd(pack.endTime);
 				String service = TextRD.getString(date, TextTypes.SERVICE, pack.service);