事件插入通知

wj-datacenter-service/src/main/java/net/wanji/datacenter/kafka/KafkaProducerService.java → wj-datacenter-service/src/main/java/net/wanji/datacenter/kafka/KafkaProducerServiceHandler.java

@@ -11,7 +11,7 @@ import javax.annotation.Resource;
 
 @Component
 @Slf4j
-public class KafkaProducerService   {
+public class KafkaProducerServiceHandler {
     private final Logger logger = LoggerFactory.getLogger(this.getClass());
 
 

wj-datacenter-service/src/main/java/net/wanji/datacenter/service/EventDataServiceImpl.java

@@ -8,7 +8,7 @@ import net.wanji.common.utils.tool.JacksonUtils;
 import net.wanji.common.utils.tool.StringUtils;
 import net.wanji.datacenter.cache.CrossGreenWaveInfoCache;
 import net.wanji.datacenter.constant.EventAbnormalEnum;
-import net.wanji.datacenter.kafka.KafkaProducerService;
+import net.wanji.datacenter.kafka.KafkaProducerServiceHandler;
 import net.wanji.datacenter.mapper.EventInfoMapper;
 import net.wanji.datacenter.pojo.dto.EventDataDTO;
 import net.wanji.datacenter.pojo.po.EventInfoPO;
@@ -32,7 +32,7 @@ public class EventDataServiceImpl implements EventDataService {
 	@Resource
 	private EventInfoMapper eventInfoMapper;
 	@Resource
-	private KafkaProducerService kafkaProducerService;
+	private KafkaProducerServiceHandler kafkaProducerService;
 
 	@Transactional(rollbackFor = Exception.class)
 	@Override