|
...
|
...
|
@@ -18,6 +18,7 @@ import com.monitor.model.response.BaseResponse; |
|
|
|
import com.monitor.mysql.mapper.MObjectInfoMapper;
|
|
|
|
import com.monitor.mysql.mapper.RabbitAlertMapper;
|
|
|
|
import com.sun.org.apache.bcel.internal.generic.NEW;
|
|
|
|
import com.sun.org.apache.xml.internal.resolver.helpers.Debug;
|
|
|
|
import org.apache.commons.lang.StringUtils;
|
|
|
|
import org.influxdb.dto.QueryResult;
|
|
|
|
import org.slf4j.Logger;
|
|
...
|
...
|
@@ -285,15 +286,22 @@ public class RabbitmqService { |
|
|
|
if (StringUtils.isNotBlank(tags)) {
|
|
|
|
|
|
|
|
String[] tagArray = StringUtils.split(",");
|
|
|
|
DEBUG.info("tagArray {}", tagArray);
|
|
|
|
|
|
|
|
for (String tag : tagArray) {
|
|
|
|
|
|
|
|
DEBUG.info("tag {} ", tag);
|
|
|
|
|
|
|
|
if (tag.startsWith("slave:")) {
|
|
|
|
|
|
|
|
String[] tagValue = tag.split(":", 2);
|
|
|
|
|
|
|
|
DEBUG.info("tagValue {}", tagValue);
|
|
|
|
|
|
|
|
if (StringUtils.isNotBlank(tagValue[1])) {
|
|
|
|
|
|
|
|
DEBUG.info("tagValue[1] {}", tagValue[1]);
|
|
|
|
|
|
|
|
List<MObjectInfo> mObjectInfos = moService.queryMObjectsInfoByHost(tagValue[1]);
|
|
|
|
|
|
|
|
DEBUG.info("query all slaves {} about ip {} ", mObjectInfos, tagValue[1]);
|
...
|
...
|
|
