anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

api的完善

Browse Source
This commit is contained in:
heavyrain.lee
2020-02-28 19:03:50 +08:00
parent 1bd060936c
commit dd5ecd09f2
6 changed files with 30 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
+2 -3
View File
@@ -50,8 +50,7 @@ import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
import java.util.function.Consumer;
import static cn.wildfirechat.proto.ProtoConstants.ChannelStatus.Channel_Status_Destoryed;
import static cn.wildfirechat.proto.ProtoConstants.ChannelState.Channel_State_Mask_Deleted;
import static cn.wildfirechat.proto.ProtoConstants.GroupMemberType.*;
import static cn.wildfirechat.proto.ProtoConstants.ModifyChannelInfoType.*;
import static cn.wildfirechat.proto.ProtoConstants.ModifyGroupInfoType.*;
@@ -2617,7 +2616,7 @@ public class MemoryMessagesStore implements IMessagesStore {
WFCMessage.ChannelInfo.Builder newInfoBuilder = oldInfo.toBuilder();
newInfoBuilder.setStatus(Channel_Status_Destoryed);
newInfoBuilder.setStatus(oldInfo.getStatus() | Channel_State_Mask_Deleted);
newInfoBuilder.setUpdateDt(System.currentTimeMillis());
mIMap.put(channelId, newInfoBuilder.build());
return ErrorCode.ERROR_CODE_SUCCESS;