Showing
1 changed file
with
2 additions
and
0 deletions
1 | package com.yohoufo.common.alarm; | 1 | package com.yohoufo.common.alarm; |
2 | 2 | ||
3 | +import com.google.common.eventbus.Subscribe; | ||
3 | import com.yoho.core.common.alarm.EventReporter; | 4 | import com.yoho.core.common.alarm.EventReporter; |
4 | import org.slf4j.Logger; | 5 | import org.slf4j.Logger; |
5 | import org.slf4j.LoggerFactory; | 6 | import org.slf4j.LoggerFactory; |
@@ -21,6 +22,7 @@ public class UfoInfluxdbEventHandler implements IEventHandler<UfoInfluxdbEvent> | @@ -21,6 +22,7 @@ public class UfoInfluxdbEventHandler implements IEventHandler<UfoInfluxdbEvent> | ||
21 | private final static String database = "ufo"; | 22 | private final static String database = "ufo"; |
22 | 23 | ||
23 | @Override | 24 | @Override |
25 | + @Subscribe | ||
24 | public void handle(UfoInfluxdbEvent event) { | 26 | public void handle(UfoInfluxdbEvent event) { |
25 | logger.info("method UfoInfluxdbEventHandler onApplicationEvent, event", event); | 27 | logger.info("method UfoInfluxdbEventHandler onApplicationEvent, event", event); |
26 | 28 |
-
Please register or login to post a comment