Showing
1 changed file
with
2 additions
and
1 deletions
@@ -10,6 +10,7 @@ import com.yohobuy.platform.common.service.redis.PlatformRedis; | @@ -10,6 +10,7 @@ import com.yohobuy.platform.common.service.redis.PlatformRedis; | ||
10 | import com.yohobuy.platform.common.util.DateUtil; | 10 | import com.yohobuy.platform.common.util.DateUtil; |
11 | import com.yohobuy.platform.dal.grass.*; | 11 | import com.yohobuy.platform.dal.grass.*; |
12 | import com.yohobuy.platform.dal.grass.model.*; | 12 | import com.yohobuy.platform.dal.grass.model.*; |
13 | +import com.yohobuy.platform.grass.mq.AutoAttentionComsumer; | ||
13 | import com.yohobuy.platform.grass.service.IGrassVirtualService; | 14 | import com.yohobuy.platform.grass.service.IGrassVirtualService; |
14 | import org.apache.commons.collections.CollectionUtils; | 15 | import org.apache.commons.collections.CollectionUtils; |
15 | import org.apache.commons.lang.StringUtils; | 16 | import org.apache.commons.lang.StringUtils; |
@@ -106,7 +107,7 @@ public class GrassUserVirtualImpl implements IGrassVirtualService{ | @@ -106,7 +107,7 @@ public class GrassUserVirtualImpl implements IGrassVirtualService{ | ||
106 | sendMessage(l); | 107 | sendMessage(l); |
107 | } | 108 | } |
108 | platformRedis.delete(MESSAGE_SENDING_FLAG); | 109 | platformRedis.delete(MESSAGE_SENDING_FLAG); |
109 | - platformRedis.delete(MESSAGE_KEY); | 110 | + platformRedis.delete(MESSAGE_KEY, "all", null); |
110 | logger.info("sendMessageTask end , message list clear success"); | 111 | logger.info("sendMessageTask end , message list clear success"); |
111 | }else if(DateUtil.getCurrentTimeSeconds() - sendTime < 600){ | 112 | }else if(DateUtil.getCurrentTimeSeconds() - sendTime < 600){ |
112 | logger.info("current message list is sending"); | 113 | logger.info("current message list is sending"); |
-
Please register or login to post a comment