extends socket interface

foudations/mogo-socket/src/main/java/com/mogo/cloud/socket/IMogoCloudSocketOnMessageListener.java

@@ -14,7 +14,8 @@ public interface IMogoCloudSocketOnMessageListener<T> {
 
     /**
      * 消息接收回调
+     * @param msgType 消息类型
      * @param obj T 业务bean数据
      */
-    void onMsgReceived(T obj);
+    void onMsgReceived(int msgType, T obj);
 }

foudations/mogo-socket/src/main/java/com/mogo/cloud/socket/SocketManager.java

@@ -6,9 +6,9 @@ import android.support.annotation.NonNull;
 
 import com.google.protobuf.ByteString;
 import com.google.protobuf.InvalidProtocolBufferException;
+import com.mogo.cloud.GsonUtil;
 import com.mogo.cloud.passport.MoGoAiCloudClient;
 import com.mogo.cloud.passport.MoGoAiCloudClientConfig;
-import com.mogo.cloud.GsonUtil;
 import com.mogo.cloud.utils.logger.Logger;
 import com.zhidao.locupload.Platform;
 import com.zhidao.ptech.connsvr.commom.protocol.MogoCommon;
@@ -147,7 +147,7 @@ public class SocketManager implements IMogoCloudSocketManager, Callback {
                     }
                     if (listener != null) {
                         Logger.d(TAG, "received msgId = %s, content = %s", msgId, payload.getPayload().toStringUtf8());
-                        listener.onMsgReceived(object);
+                        listener.onMsgReceived(msgType, object);
                     }
                 }
             }