diff --git a/app/src/main/java/com/mogo/cloud/RealTimeActivity.java b/app/src/main/java/com/mogo/cloud/RealTimeActivity.java
index c4dfce9..c06b9c7 100644
--- a/app/src/main/java/com/mogo/cloud/RealTimeActivity.java
+++ b/app/src/main/java/com/mogo/cloud/RealTimeActivity.java
@@ -3,6 +3,7 @@ package com.mogo.cloud;
 import android.os.Bundle;
 import android.util.Log;
 import android.widget.Button;
+import android.widget.TextView;
 
 import androidx.annotation.Nullable;
 import androidx.appcompat.app.AppCompatActivity;
@@ -40,7 +41,6 @@ public class RealTimeActivity extends AppCompatActivity implements IMogoCloudOnM
         snapshotStopButton.setOnClickListener(view -> {
             stopRealTimeService();
         });
-
     }
 
     private void setConfig() {
diff --git a/foudations/mogo-socket/src/main/java/com/mogo/cloud/socket/SocketManager.java b/foudations/mogo-socket/src/main/java/com/mogo/cloud/socket/SocketManager.java
index 8563c9d..b13bfea 100644
--- a/foudations/mogo-socket/src/main/java/com/mogo/cloud/socket/SocketManager.java
+++ b/foudations/mogo-socket/src/main/java/com/mogo/cloud/socket/SocketManager.java
@@ -63,14 +63,14 @@ public class SocketManager implements IMogoCloudSocketManager, Callback {
      * <p>
      * key - msgType
      */
-    private Map<Integer, List<IMogoCloudSocketOnMessageListener>> mListeners = new ConcurrentHashMap<>();
+    private final Map<Integer, List<IMogoCloudSocketOnMessageListener>> mListeners = new ConcurrentHashMap<>();
 
     /**
      * 管理消息回执
      * <p>
      * key - msgId
      */
-    private Map<Long, IMogoCloudSocketMsgAckListener> mAckListeners = new ConcurrentHashMap<>();
+    private final Map<Long, IMogoCloudSocketMsgAckListener> mAckListeners = new ConcurrentHashMap<>();
 
 
     public static final int MAX_CAP = 64; //保证充足的容量应对非常延时的推送
@@ -122,6 +122,7 @@ public class SocketManager implements IMogoCloudSocketManager, Callback {
         Logger.d(TAG, "sendMsg  msgId : " + body.getMsgId());
         final byte[] pb = convertToPBBytes(body.getMsgType(), objectToBytes(body.getContent()));
         SocketClient.getInstance().sendData(mAppId, MogoCommon.Product.mogoBussiness.getNumber(), pb, MogoConnsvr.MsgType.mogoMsgTypeCollectSvrNoRspReq.getNumber(), true, body.getMsgId());
+        mAckListeners.put( body.getMsgId(), listener );
     }
 
     @Override
@@ -211,7 +212,6 @@ public class SocketManager implements IMogoCloudSocketManager, Callback {
 
     public synchronized void release() {
         mListeners.clear();
-        mListeners = null;
         cloudClientConfig = null;
         mInstance = null;
     }
diff --git a/modules/mogo-realtime/src/main/java/com/mogo/realtime/socket/SocketHandler.java b/modules/mogo-realtime/src/main/java/com/mogo/realtime/socket/SocketHandler.java
index 5db6382..118a6db 100644
--- a/modules/mogo-realtime/src/main/java/com/mogo/realtime/socket/SocketHandler.java
+++ b/modules/mogo-realtime/src/main/java/com/mogo/realtime/socket/SocketHandler.java
@@ -59,6 +59,9 @@ public class SocketHandler {
      */
     public void initSocket(Context context, String appId) {
         SocketManager.getInstance().init(context, appId);
+        int msgType = 0x040003;
+        Log.i(TAG,"msgType : " + msgType);
+        Log.i(TAG,"msgType integer : " + (Integer)msgType);
         SocketManager.getInstance().registerOnMessageListener(0x040002, onMessageListener);
         SocketManager.getInstance().registerOnMessageListener(0x040003, onMessageListener);
     }