提交 8bf9f954 编写于 作者: hebao@lab.ibiz5.com's avatar hebao@lab.ibiz5.com

LocalMsg消息处理后内容清空,解决报表构建内存溢出问题

上级 db56e1b7
...@@ -61,18 +61,21 @@ public class LocalMsgEventHandler implements EventHandler<LocalMsgEvent> { ...@@ -61,18 +61,21 @@ public class LocalMsgEventHandler implements EventHandler<LocalMsgEvent> {
String tags = localMsgEvent.getTags(); String tags = localMsgEvent.getTags();
if("Engine".equalsIgnoreCase(tags)) { if("Engine".equalsIgnoreCase(tags)) {
EngineMQMsg engineMQMsg = localMsgEvent.getMessage(EngineMQMsg.class); EngineMQMsg engineMQMsg = localMsgEvent.getMessage(EngineMQMsg.class);
localMsgEvent.setBody(null);
if (log.isDebugEnabled()) { if (log.isDebugEnabled()) {
log.debug("EngineMQMsg Event Handler: {}", engineMQMsg.getBatch()); log.debug("EngineMQMsg Event Handler: {}", engineMQMsg.getBatch());
} }
ruleEngineExService.processData(engineMQMsg); ruleEngineExService.processData(engineMQMsg);
}else if("Build".equalsIgnoreCase(tags)){ }else if("Build".equalsIgnoreCase(tags)){
EngineMQMsg engineMQMsg = localMsgEvent.getMessage(EngineMQMsg.class); EngineMQMsg engineMQMsg = localMsgEvent.getMessage(EngineMQMsg.class);
localMsgEvent.setBody(null);
if (log.isDebugEnabled()) { if (log.isDebugEnabled()) {
log.debug("BuildMQMsg Event Handler: {}", engineMQMsg.getBatch()); log.debug("BuildMQMsg Event Handler: {}", engineMQMsg.getBatch());
} }
daBuildExService.processData(engineMQMsg); daBuildExService.processData(engineMQMsg);
}else if("SqlResult".equalsIgnoreCase(tags)){ }else if("SqlResult".equalsIgnoreCase(tags)){
SqlResultsMQMsg resultsMQMsg = localMsgEvent.getMessage(SqlResultsMQMsg.class); SqlResultsMQMsg resultsMQMsg = localMsgEvent.getMessage(SqlResultsMQMsg.class);
localMsgEvent.setBody(null);
if (log.isDebugEnabled()) { if (log.isDebugEnabled()) {
log.debug("SqlResultMsgProcess Event Handler: {}", resultsMQMsg.getMsgId()); log.debug("SqlResultMsgProcess Event Handler: {}", resultsMQMsg.getMsgId());
} }
...@@ -103,6 +106,7 @@ public class LocalMsgEventHandler implements EventHandler<LocalMsgEvent> { ...@@ -103,6 +106,7 @@ public class LocalMsgEventHandler implements EventHandler<LocalMsgEvent> {
else if (localMsgEvent.getType()==2) { else if (localMsgEvent.getType()==2) {
ResultsMQMsg resultsMQMsg = localMsgEvent.getMessage(ResultsMQMsg.class); ResultsMQMsg resultsMQMsg = localMsgEvent.getMessage(ResultsMQMsg.class);
localMsgEvent.setBody(null);
if (log.isDebugEnabled()) { if (log.isDebugEnabled()) {
log.debug("ResultsMQMsg Event Handler: {}", resultsMQMsg.getKeyValueField()); log.debug("ResultsMQMsg Event Handler: {}", resultsMQMsg.getKeyValueField());
} }
......
Markdown 格式
0% or
您添加了 0 到此讨论。请谨慎行事。
先完成此消息的编辑!
想要评论请 注册