添加socket1.0回调支持

websocket/src/main/java/com/zhimai/websocket/util/MsgWebSocketUtil.java

@@ -478,17 +478,30 @@ public class MsgWebSocketUtil {
                 case "init"://初始化/验证
                     sendBind(jsonObject);
                     break;
-                case "success"://验证成功//2.0有消息的时候，type返回的竟然也是这个 0.o
-                    //这里优化，如果是通知 有新消息，请求接口后 筛重 再塞队列
-                    if (StringUtil.isNotNull(jsonObject.optString("new_message"))) {
-                        if (jsonObject.optString("new_message").equals("true")) {
-                            getSocketServiceMessage();
+                case "success":
+                    //不是socket1.0
+                    if (!isSocket2) {
+                        //判断是否存在tag，tag不为空就 通知socket服务端，收到了此消息-----------
+                        if (useQueue) {//如果开启队列，消息加入队列---------------------------------------------
+                            MessageQueue.getInstance().enQueue(message);
+                        } else {//直接 回调 传消息
+                            if (socketMessageListener != null) {
+                                socketMessageListener.recieveMessage(message);
+                            } else {
+                                Logger.e(TAG, "socketMessageListener==null");
+                            }
                         }
                     } else {
-                        Logger.e(TAG, "socket绑定成功");
+                        //验证成功//2.0有消息的时候，type返回的竟然也是这个 0.o
+                        //这里优化，如果是通知 有新消息，请求接口后 筛重 再塞队列
+                        if (StringUtil.isNotNull(jsonObject.optString("new_message"))) {
+                            if (jsonObject.optString("new_message").equals("true")) {
+                                getSocketServiceMessage();
+                            }
+                        } else {
+                            Logger.e(TAG, "socket绑定成功");
+                        }
                     }
-
-
                     //判断是否存在tag，tag不为空就 通知socket服务端，收到了此消息-----------
 //                    if (useQueue) {//如果开启队列，消息加入队列---------------------------------------------
 //                        MessageQueue.getInstance().enQueue(message);