fanxb/bookmark
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 6 Wiki Activity

fix:修复redis消息消费错误bug

Browse Source
This commit is contained in:
fanxb 2020-05-17 15:59:34 +08:00
parent ee84f8d68e
commit 8884d2ca43
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
bookMarkService/business/bookmark/src/main/java/com/fanxb/bookmark/business/bookmark/consumer/PinyinUpdateConsumer.java
View File

@ -39,7 +39,7 @@ public class PinyinUpdateConsumer implements RedisConsumer {
for (int i = 0, size = bookmarks.size(); i < size; i++) { for (int i = 0, size = bookmarks.size(); i < size; i++) {
bookmarkDao.updateSearchKey(bookmarks.get(i).getBookmarkId(), resList.get(i)); bookmarkDao.updateSearchKey(bookmarks.get(i).getBookmarkId(), resList.get(i));
} }
//更新本用户书签更新时间 //更新本用户书签更新版本
RedisUtil.addToMq(RedisConstant.BOOKMARK_UPDATE_VERSION, new UserBookmarkUpdate(bookmarks.get(0).getUserId())); RedisUtil.addToMq(RedisConstant.BOOKMARK_UPDATE_VERSION, bookmarks.get(0).getUserId());
} }
} }

2
bookMarkService/business/bookmark/src/main/java/com/fanxb/bookmark/business/bookmark/service/impl/PinYinServiceImpl.java
View File

@ -61,7 +61,7 @@ public class PinYinServiceImpl implements PinYinService {
i = bookmarks.get(SIZE - 1).getBookmarkId(); i = bookmarks.get(SIZE - 1).getBookmarkId();
} }
//更新所有用户的上次刷新时间 //更新所有用户的上次刷新时间
RedisUtil.addToMq(RedisConstant.BOOKMARK_UPDATE_VERSION, new UserBookmarkUpdate(-1, System.currentTimeMillis())); RedisUtil.addToMq(RedisConstant.BOOKMARK_UPDATE_VERSION, -1);
} }
@Override @Override