Introducing new features.异步写入聊天记录

 package com.crossoverjie.cim.client.config;
 
 import com.crossoverjie.cim.client.handle.MsgHandleCaller;
+import com.crossoverjie.cim.client.service.impl.MsgCallBackListener;
 import com.crossoverjie.cim.common.constant.Constants;
 import com.crossoverjie.cim.common.protocol.CIMRequestProto;
 import com.google.common.util.concurrent.ThreadFactoryBuilder;
@@ -87,9 +88,7 @@ public class BeanConfig {
      */
     @Bean
     public MsgHandleCaller buildCaller(){
-        MsgHandleCaller caller = new MsgHandleCaller(msg -> {
-            //处理业务逻辑，或者自定义实现接口
-        }) ;
+        MsgHandleCaller caller = new MsgHandleCaller(new MsgCallBackListener()) ;
 
         return caller ;
     }

@@ -72,8 +72,6 @@ public class AsyncMsgLogger implements MsgLogger {
 
     private void writeLog(String msg) {
 
-        msg = appConfiguration.getUserName() + ":" + "【" + msg + "】";
-
         LocalDate today = LocalDate.now();
         int year = today.getYear();
         int month = today.getMonthValue();

+package com.crossoverjie.cim.client.service.impl;
+
+import com.crossoverjie.cim.client.service.CustomMsgHandleListener;
+import com.crossoverjie.cim.client.service.MsgLogger;
+import com.crossoverjie.cim.client.util.SpringBeanFactory;
+
+/**
+ * Function:自定义收到消息回调
+ *
+ * @author crossoverJie
+ *         Date: 2019/1/6 17:49
+ * @since JDK 1.8
+ */
+public class MsgCallBackListener implements CustomMsgHandleListener {
+
+
+    private MsgLogger msgLogger ;
+
+    public MsgCallBackListener() {
+        this.msgLogger = SpringBeanFactory.getBean(MsgLogger.class) ;
+    }
+
+    @Override
+    public void handle(String msg) {
+        msgLogger.log(msg) ;
+    }
+}