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

接收好友请求时，会话不产生

Browse Source
This commit is contained in:
heavyrain2012
2019-03-17 20:28:15 +08:00
parent 773bf2c255
commit a9386ea275
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/imhandler/HandleFriendRequestHandler.java
+9 -2
View File
@@ -29,22 +29,29 @@ public class HandleFriendRequestHandler extends IMHandler<WFCMessage.HandleFrien
if (errorCode == ERROR_CODE_SUCCESS) {
long messageId = MessageShardingUtil.generateId();
long timestamp = System.currentTimeMillis();
builder.setMessageId(messageId);
saveAndPublish(request.getTargetUid(), null, builder.build(), System.currentTimeMillis());
builder.setServerTimestamp(timestamp);
saveAndPublish(request.getTargetUid(), null, builder.build(), timestamp);
WFCMessage.MessageContent.Builder contentBuilder = WFCMessage.MessageContent.newBuilder().setType(90).setContent("以上是打招呼信息");
builder = WFCMessage.Message.newBuilder();
builder.setFromUser(request.getTargetUid());
builder.setConversation(WFCMessage.Conversation.newBuilder().setTarget(fromUser).setLine(0).setType(ProtoConstants.ConversationType.ConversationType_Private).build());
builder.setContent(contentBuilder);
timestamp = System.currentTimeMillis();
builder.setServerTimestamp(timestamp);
messageId = MessageShardingUtil.generateId();
builder.setMessageId(messageId);
saveAndPublish(request.getTargetUid(), null, builder.build(), System.currentTimeMillis());
saveAndPublish(request.getTargetUid(), null, builder.build(), timestamp);
contentBuilder.setContent("你们已经成为好友了，现在可以开始聊天了");
builder.setContent(contentBuilder);
messageId = MessageShardingUtil.generateId();
builder.setMessageId(messageId);
timestamp = System.currentTimeMillis();
builder.setServerTimestamp(timestamp);
saveAndPublish(request.getTargetUid(), null, builder.build(), System.currentTimeMillis());
publisher.publishNotification(IMTopic.NotifyFriendTopic, request.getTargetUid(), heads[0]);