Commit 69667349 by Future

代码调试

parent f7476fd4
......@@ -186,15 +186,15 @@ public class NormalChatAction {
// imConversationMembersService.updateBatchById(tempMemberToUpdate);
// }
// }
String key = "push_" + conversation.getId();
String value = redisUtils.getKey(key);
final Boolean isPush;
if (StringUtils.isBlank(value)) {
isPush = Boolean.TRUE;
redisUtils.addKey(key, "1", Duration.ofMinutes(5));
} else {
isPush = Boolean.FALSE;
}
// String key = "push_" + conversation.getId();
// String value = redisUtils.getKey(key);
final Boolean isPush = true;
// if (StringUtils.isBlank(value)) {
// isPush = Boolean.TRUE;
// redisUtils.addKey(key, "1", Duration.ofMinutes(5));
// } else {
// isPush = Boolean.FALSE;
// }
// 多线程处理消息下发
for (ImConversationMembers member : membersList) {
if (member.getFkClientId().equals(imClientSender.getId())) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment