diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/mq/listener/OpenDataProjectChangeEventListener.java b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/mq/listener/OpenDataProjectChangeEventListener.java
index 819c1975ce..e82e2cd8c9 100644
--- a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/mq/listener/OpenDataProjectChangeEventListener.java
+++ b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/mq/listener/OpenDataProjectChangeEventListener.java
@@ -58,7 +58,7 @@ public class OpenDataProjectChangeEventListener implements MessageListenerConcur
         String msg = new String(messageExt.getBody());
         String topic = messageExt.getTopic();
         String tags = messageExt.getTags();
-        String pendingMsgLabel = messageExt.getUserProperty(MQUserPropertys.PENDING_MSG_LABEL);
+        String pendingMsgLabel = messageExt.getUserProperty(MQUserPropertys.BLOCKED_MSG_LABEL);
 
         //messageExt.propert
 
@@ -102,7 +102,7 @@ public class OpenDataProjectChangeEventListener implements MessageListenerConcur
      * @date 2021.10.14 16:32:32
      */
     private void removePendingMqMsgCache(String pendingMsgLabel) {
-        String key = RedisKeys.pendingMqMsgKey(pendingMsgLabel);
+        String key = RedisKeys.blockedMqMsgKey(pendingMsgLabel);
         redisUtils.delete(key);
     }
 }
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/GroupAchievementCustomListener.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/GroupAchievementCustomListener.java
index 0462c3fe60..6644a29dc3 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/GroupAchievementCustomListener.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/GroupAchievementCustomListener.java
@@ -59,7 +59,7 @@ public class GroupAchievementCustomListener  implements MessageListenerConcurren
     private void consumeMessage(MessageExt messageExt) {
         logger.info("receive msg:{}", JSON.toJSONString(messageExt));
         String msg = new String(messageExt.getBody());
-        String pendingMsgLabel = messageExt.getUserProperty(MQUserPropertys.PENDING_MSG_LABEL);
+        String pendingMsgLabel = messageExt.getUserProperty(MQUserPropertys.BLOCKED_MSG_LABEL);
 
         GroupAchievementMQMsg msgObj = JSON.parseObject(msg, GroupAchievementMQMsg.class);
         if (msgObj == null){
@@ -118,7 +118,7 @@ public class GroupAchievementCustomListener  implements MessageListenerConcurren
      * @date 2021.10.14 16:32:32
      */
     private void removePendingMqMsgCache(String pendingMsgLabel) {
-        String key = RedisKeys.pendingMqMsgKey(pendingMsgLabel);
+        String key = RedisKeys.blockedMqMsgKey(pendingMsgLabel);
         redisUtils.delete(key);
         logger.info("【小组成就事件监听器】删除mq滞留消息缓存成功,penddingMsgLabel:{}", pendingMsgLabel);
     }