发消息不用多线程处理

core/src/main/java/com/wecloud/im/action/NormalChatAction.java

@@ -12,7 +12,6 @@ import com.wecloud.im.entity.ImConversationMembers;
 import com.wecloud.im.entity.ImInbox;
 import com.wecloud.im.entity.ImMessage;
 import com.wecloud.im.entity.ImMessageOnlineSend;
-import com.wecloud.im.executor.SendMsgThreadPool;
 import com.wecloud.im.friend.entity.ImFriend;
 import com.wecloud.im.friend.service.ImFriendService;
 import com.wecloud.im.mq.MqSender;
@@ -181,9 +180,7 @@ public class NormalChatAction {
                 continue;
             }
             log.info("6");
-            SendMsgThreadPool.SEND_MSG_THREAD_POOL_EXECUTOR.execute(() -> {
-                this.sendMsgToMember(imApplication, member, imMessageOnlineSend, data.getPush(), isPush);
-            });
+            this.sendMsgToMember(imApplication, member, imMessageOnlineSend, data.getPush(), isPush);
         }
 
         // 响应发送方消息id等信息