提交 d99915b3 编写于 作者: L leon.li

add configures for ProjectUpdateTask

上级 743ecf76
......@@ -17,6 +17,7 @@ import com.dianping.cat.report.task.DefaultTaskConsumer;
import com.dianping.cat.report.task.exceptionAlert.ExceptionAlert;
import com.dianping.cat.report.task.metric.MetricAlert;
import com.dianping.cat.report.task.metric.SwitchAlert;
import com.dianping.cat.report.task.product.ProductUpdateTask;
import com.dianping.cat.report.view.DomainNavManager;
import com.dianping.cat.system.config.ConfigReloadTask;
import com.dianping.cat.system.notify.ScheduledMailTask;
......@@ -56,6 +57,10 @@ public class CatHomeModule extends AbstractModule {
Threads.forGroup("Cat").start(metricAlert);
Threads.forGroup("Cat").start(exceptionAlert);
}
ProductUpdateTask productUpdateTask = ctx.lookup(ProductUpdateTask.class);
Threads.forGroup("Cat").start(productUpdateTask);
executeAlarmModule(ctx);
}
......
......@@ -18,6 +18,7 @@ import com.dianping.cat.consumer.metric.MetricConfigManager;
import com.dianping.cat.consumer.metric.ProductLineConfigManager;
import com.dianping.cat.consumer.top.TopAnalyzer;
import com.dianping.cat.core.config.ConfigDao;
import com.dianping.cat.core.dal.HostinfoDao;
import com.dianping.cat.core.dal.ProjectDao;
import com.dianping.cat.home.dal.report.EventDao;
import com.dianping.cat.home.dal.report.TopologyGraphDao;
......@@ -48,12 +49,13 @@ import com.dianping.cat.report.page.userMonitor.graph.DefaultUserMonitGraphCreat
import com.dianping.cat.report.page.userMonitor.graph.UserMonitorGraphCreator;
import com.dianping.cat.report.service.ReportService;
import com.dianping.cat.report.task.exceptionAlert.ExceptionAlert;
import com.dianping.cat.report.task.metric.MetricAlertConfig;
import com.dianping.cat.report.task.metric.AlertInfo;
import com.dianping.cat.report.task.metric.MetricAlert;
import com.dianping.cat.report.task.metric.MetricAlertConfig;
import com.dianping.cat.report.task.metric.RemoteMetricReportService;
import com.dianping.cat.report.task.metric.SwitchAlert;
import com.dianping.cat.report.task.metric.SwitchAlertConfig;
import com.dianping.cat.report.task.product.ProductUpdateTask;
import com.dianping.cat.report.view.DomainNavManager;
import com.dianping.cat.system.config.BugConfigManager;
import com.dianping.cat.system.config.ConfigReloadTask;
......@@ -106,7 +108,7 @@ public class ComponentsConfigurator extends AbstractResourceConfigurator {
all.add(C(MetricGroupConfigManager.class).req(ConfigDao.class));
all.add(C(MetricAggregationConfigManager.class).req(ConfigDao.class));
all.add(C(MetricRuleConfigManager.class).req(ConfigDao.class));
all.add(C(TopologyGraphItemBuilder.class).req(TopologyGraphConfigManager.class));
......@@ -152,7 +154,7 @@ public class ComponentsConfigurator extends AbstractResourceConfigurator {
all.add(C(RemoteMetricReportService.class).req(ServerConfigManager.class));
all.add(C(MetricAlertConfig.class));
all.add(C(SwitchAlertConfig.class));
all.add(C(AlertInfo.class));
......@@ -176,6 +178,10 @@ public class ComponentsConfigurator extends AbstractResourceConfigurator {
all.addAll(new CatDatabaseConfigurator().defineComponents());
all.addAll(new UserDatabaseConfigurator().defineComponents());
// update project database
all.add(C(ProductUpdateTask.class)//
.req(ProjectDao.class, HostinfoDao.class));
// web, please keep it last
all.addAll(new WebComponentConfigurator().defineComponents());
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册