hxb
2024-08-20 0a8fd4aa92555875f58f67144c2c0c0a20a200af
HDLSDK/hdl-connect/src/main/java/com/hdl/sdk/connect/socket/HdlSocketHelper.java
@@ -91,7 +91,7 @@
     * 注册监听
     */
    void registerListener() {
        if (!TextUtils.isEmpty(observeTopic)) {
        if (listener != null && !TextUtils.isEmpty(observeTopic)) {
            EventDispatcher.getInstance().register(observeTopic, eventListener);
//            LogUtils.i("HdlSocketHelper", "register event");
        }
@@ -173,7 +173,7 @@
                            }
                        }
                    } catch (Exception e) {
                        e.printStackTrace();
                        LogUtils.e("发送数据失败:" + e.getMessage());
                    }
                } else {
                    //超出重发次数并没有收到回复
@@ -206,13 +206,17 @@
    private void notifyFailure() {
        //移除监听
        removeListener();
        if (sendThread != null) {
            sendThread.shutdownNow();
            sendThread = null;
        }
        if (listener != null) {
            listener.onFailure();
            listener = null;
        try {
            if (sendThread != null) {
                sendThread.shutdownNow();
                sendThread = null;
            }
            if (listener != null) {
                listener.onFailure();
                listener = null;
            }
        } catch (Exception e) {
        }
    }
}