From 2ccf8392bf7d3a597ed46335df21ec6d8d66a036 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=91=A3=E5=AE=8F=E5=AE=87?= <martindhy@gmail.com>
Date: Thu, 4 Feb 2021 17:40:51 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E4=BA=86=E9=95=BF=E8=BF=9E?=
 =?UTF-8?q?=E6=8E=A5=E6=95=B0=E6=8D=AE=E6=8E=A5=E5=8F=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/mogo/cloud/live/socket/SocketMsgUtils.java | 14 +++++++++++++-
 1 file changed, 13 insertions(+), 1 deletion(-)

diff --git a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/socket/SocketMsgUtils.java b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/socket/SocketMsgUtils.java
index 429b5ea..f05cd01 100644
--- a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/socket/SocketMsgUtils.java
+++ b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/socket/SocketMsgUtils.java
@@ -4,13 +4,14 @@ import android.content.Context;
 import android.util.Log;
 
 import com.mogo.cloud.socket.IMogoCloudSocketMsgAckListener;
+import com.mogo.cloud.socket.IMogoCloudSocketOnMessageListener;
 import com.mogo.cloud.socket.MsgBody;
 import com.mogo.cloud.socket.SocketManager;
 
 /**
  * Socket常链接工具类
  */
-public class SocketMsgUtils implements IMogoCloudSocketMsgAckListener {
+public class SocketMsgUtils implements IMogoCloudSocketMsgAckListener, IMogoCloudSocketOnMessageListener {
     private static final String TAG = "SocketMsgUtils";
 
     private static final String appId = "liveStream";
@@ -43,6 +44,7 @@ public class SocketMsgUtils implements IMogoCloudSocketMsgAckListener {
     private void initSocket() {
         mSocketManager = SocketManager.getInstance();
         mSocketManager.init(mContext);
+        mSocketManager.registerOnMessageListener(401016, this);
     }
 
     /**
@@ -66,4 +68,14 @@ public class SocketMsgUtils implements IMogoCloudSocketMsgAckListener {
         Log.i(TAG, "msgId=" + msgId);
 
     }
+
+    @Override
+    public Class target() {
+        return Object.class;
+    }
+
+    @Override
+    public void onMsgReceived(Object obj) {
+        Log.i(TAG, "onMsgReceived: obj=" + obj);
+    }
 }