|
@@ -60,7 +60,7 @@ public class ChatProcessor extends WebSoketSupport implements ProcessorInterface
|
|
/*List<IMMessage> chats = Optional.ofNullable(redis.get("ALLCHATS:" + sessionId, List.class)).orElse(new ArrayList());
|
|
/*List<IMMessage> chats = Optional.ofNullable(redis.get("ALLCHATS:" + sessionId, List.class)).orElse(new ArrayList());
|
|
chats.add(request);
|
|
chats.add(request);
|
|
redis.setValue("ALLCHATS:" + sessionId, chats);*/
|
|
redis.setValue("ALLCHATS:" + sessionId, chats);*/
|
|
- redis.lLeftPush("ALLCHATS:" + sessionId, JSONObject.toJSONString(request));
|
|
|
|
|
|
+ redis.lRightPush("ALLCHATS:" + sessionId, JSONObject.toJSONString(request));
|
|
// ChatMsgEntity entity = new ChatMsgEntity();
|
|
// ChatMsgEntity entity = new ChatMsgEntity();
|
|
// entity.setMsg(request.getMsg());
|
|
// entity.setMsg(request.getMsg());
|
|
// entity.setFromUser(request.getFromUser());
|
|
// entity.setFromUser(request.getFromUser());
|