Browse Source

修复:

1.OpenDataOrgChangeEventListener打印日志内容错误
dev_shibei_match
wxz 4 years ago
parent
commit
89a8c0cb47
  1. 2
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/mq/ProjectChangedCustomListener.java
  2. 2
      epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/mq/listener/IssueProjectCategoryTagInitListener.java
  3. 2
      epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/mq/listener/InitCustomerOrgRolesListener.java
  4. 2
      epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/mq/listener/OpenDataOrgChangeEventListener.java
  5. 2
      epmet-module/oper-customize/oper-customize-server/src/main/java/com/epmet/mq/listener/InitCustomerComponentsListener.java
  6. 2
      epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/GroupAchievementCustomListener.java

2
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/mq/ProjectChangedCustomListener.java

@ -181,7 +181,7 @@ public class ProjectChangedCustomListener implements MessageListenerConcurrently
private void removePendingMqMsgCache(String pendingMsgLabel) { private void removePendingMqMsgCache(String pendingMsgLabel) {
String key = RedisKeys.pendingMqMsgKey(pendingMsgLabel); String key = RedisKeys.pendingMqMsgKey(pendingMsgLabel);
redisUtils.delete(key); redisUtils.delete(key);
logger.info("【项目变动事件监听器】删除mq滞留消息缓存失败:{}", pendingMsgLabel); logger.info("【项目变动事件监听器】删除mq滞留消息缓存成功,penddingMsgLabel:{}", pendingMsgLabel);
} }
/*@Override /*@Override

2
epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/mq/listener/IssueProjectCategoryTagInitListener.java

@ -100,6 +100,6 @@ public class IssueProjectCategoryTagInitListener implements MessageListenerConcu
private void removePendingMqMsgCache(String pendingMsgLabel) { private void removePendingMqMsgCache(String pendingMsgLabel) {
String key = RedisKeys.pendingMqMsgKey(pendingMsgLabel); String key = RedisKeys.pendingMqMsgKey(pendingMsgLabel);
redisUtils.delete(key); redisUtils.delete(key);
logger.info("【议题/项目分类标签初始化事件监听器】删除mq滞留消息缓存失败:{}", pendingMsgLabel); logger.info("【议题/项目分类标签初始化事件监听器】删除mq滞留消息缓存成功,penddingMsgLabel:{}", pendingMsgLabel);
} }
} }

2
epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/mq/listener/InitCustomerOrgRolesListener.java

@ -131,7 +131,7 @@ public class InitCustomerOrgRolesListener implements MessageListenerConcurrently
private void removePendingMqMsgCache(String pendingMsgLabel) { private void removePendingMqMsgCache(String pendingMsgLabel) {
String key = RedisKeys.pendingMqMsgKey(pendingMsgLabel); String key = RedisKeys.pendingMqMsgKey(pendingMsgLabel);
redisUtils.delete(key); redisUtils.delete(key);
logger.info("【客户初始化事件监听器】删除mq滞留消息缓存失败,pendingMsgLabel:{}", pendingMsgLabel); logger.info("【客户初始化事件监听器】删除mq滞留消息缓存成功,penddingMsgLabel:{}", pendingMsgLabel);
} }
/* @Override /* @Override

2
epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/mq/listener/OpenDataOrgChangeEventListener.java

@ -92,6 +92,6 @@ public class OpenDataOrgChangeEventListener implements MessageListenerConcurrent
private void removePendingMqMsgCache(String pendingMsgLabel) { private void removePendingMqMsgCache(String pendingMsgLabel) {
String key = RedisKeys.pendingMqMsgKey(pendingMsgLabel); String key = RedisKeys.pendingMqMsgKey(pendingMsgLabel);
redisUtils.delete(key); redisUtils.delete(key);
logger.info("【开放数据事件监听器】删除mq滞留消息缓存失败,pendingMsgLabel:{}", pendingMsgLabel); logger.info("【开放数据事件监听器】删除mq滞留消息缓存成功,pendingMsgLabel:{}", pendingMsgLabel);
} }
} }

2
epmet-module/oper-customize/oper-customize-server/src/main/java/com/epmet/mq/listener/InitCustomerComponentsListener.java

@ -98,7 +98,7 @@ public class InitCustomerComponentsListener implements MessageListenerConcurrent
private void removePendingMqMsgCache(String pendingMsgLabel) { private void removePendingMqMsgCache(String pendingMsgLabel) {
String key = RedisKeys.pendingMqMsgKey(pendingMsgLabel); String key = RedisKeys.pendingMqMsgKey(pendingMsgLabel);
redisUtils.delete(key); redisUtils.delete(key);
logger.info("【开放数据事件监听器】删除mq滞留消息缓存失败,pendingMsgLabel:{}", pendingMsgLabel); logger.info("【开放数据事件监听器】删除mq滞留消息缓存成功,penddingMsgLabel:{}", pendingMsgLabel);
} }
/* @Override /* @Override

2
epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/GroupAchievementCustomListener.java

@ -120,7 +120,7 @@ public class GroupAchievementCustomListener implements MessageListenerConcurren
private void removePendingMqMsgCache(String pendingMsgLabel) { private void removePendingMqMsgCache(String pendingMsgLabel) {
String key = RedisKeys.pendingMqMsgKey(pendingMsgLabel); String key = RedisKeys.pendingMqMsgKey(pendingMsgLabel);
redisUtils.delete(key); redisUtils.delete(key);
logger.info("【小组成就事件监听器】删除mq滞留消息缓存失败,pendingMsgLabel:{}", pendingMsgLabel); logger.info("【小组成就事件监听器】删除mq滞留消息缓存成功,penddingMsgLabel:{}", pendingMsgLabel);
} }
/*@Override /*@Override

Loading…
Cancel
Save