|
@@ -6,13 +6,12 @@ import com.persagy.apm.energyalarmstarter.alarmengine.feign.AlarmCondition;
|
|
|
import com.persagy.apm.energyalarmstarter.alarmengine.jms.model.DmpMessage;
|
|
|
import com.persagy.apm.energyalarmstarter.alarmengine.service.AlarmRecordMsgHandler;
|
|
|
import io.netty.channel.ChannelHandler;
|
|
|
-import io.netty.channel.ChannelInboundHandlerAdapter;
|
|
|
import lombok.SneakyThrows;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
|
|
|
|
|
- * @description: Netty报警息处理中心
|
|
|
+ * @description: 报警引擎消息处理类
|
|
|
* @author: lixing
|
|
|
* @company: Persagy Technology Co.,Ltd
|
|
|
* @since: 2020/11/30 10:31 上午
|
|
@@ -20,7 +19,7 @@ import org.springframework.beans.factory.annotation.Autowired;
|
|
|
*/
|
|
|
@Slf4j
|
|
|
@ChannelHandler.Sharable
|
|
|
-public class AlarmEngineMsgHandler extends ChannelInboundHandlerAdapter {
|
|
|
+public class AlarmEngineMsgHandler {
|
|
|
@Autowired
|
|
|
private AlarmRecordMsgHandler alarmRecordMsgHandler;
|
|
|
|