From c3dbede3ee4e76966374750065f40c3295ddc643 Mon Sep 17 00:00:00 2001
From: xufenglei <xufenglei>
Date: Thu, 02 Nov 2017 13:41:16 +0800
Subject: [PATCH] 增加 错误提示
---
src/main/java/com/moral/monitor/listener/Listener.java | 6 ++++--
1 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/moral/monitor/listener/Listener.java b/src/main/java/com/moral/monitor/listener/Listener.java
index 70dcf96..0e00129 100644
--- a/src/main/java/com/moral/monitor/listener/Listener.java
+++ b/src/main/java/com/moral/monitor/listener/Listener.java
@@ -18,11 +18,15 @@
/*���������������*/
public class Listener implements MessageListener {
+
@Resource
RabbitTemplate rabbitTemplate;
+
@Resource
TaskDao taskDao;
+
private Logger logger = LoggerFactory.getLogger(Listener.class);
+
public void onMessage(Message message) {
logger.warn("���������������������������=" + Thread.currentThread().getName());
@@ -63,7 +67,6 @@
removeNotBind(receiveMsgMap,exsensorMap,bindsensor);
}
-
//���������������������������������������������
List<State> states = taskDao.findstateBymac(mac);
updateOrinsertstate(receiveMsgMap, mac, exsensorMap);
@@ -72,7 +75,6 @@
} else {
insertTohistoryDistinct(receiveMsgMap,mac,exsensorMap,states);
}
-
//������������������
List<Critical> criticals = taskDao.findcritical();
--
Gitblit v1.8.0