android - 无法在 Koush AndroidAsync 中获取断开回调事件？

Question

我已经使用 koushikdutta 库在我的 android 应用程序中实现了 websocket 客户端。我想在我的实现中获得自动重新连接功能，但是当我关闭移动 wifi 并重新打开时，我无法重新连接，因为 setClosedCallback/setEndCallback 不起作用。这是我的实现：

 public void disconnectWebsocket() {
        if (mConnection != null) {
            mConnection.setClosedCallback(new CompletedCallback() {
                @Override
                public void onCompleted(Exception ex) {
                    Log.i(TAG, "Destroying websocket");
                    MiscUtils.displayToast(activity, "Destroying websocket", Toast.LENGTH_SHORT);
                }
            });
            mConnection.close();
            mConnection = null;
            authenticationInfo=null;
        }
    if (handler != null) {
        handler.removeCallbacks(runnableCallback);
    }
    handler = null;
}

private final TrustManager trm = new X509TrustManager() {
    public X509Certificate[] getAcceptedIssuers() {
        return null;
    }
    public void checkClientTrusted(X509Certificate[] certs, String authType) {}
    public void checkServerTrusted(X509Certificate[] certs, String authType) {}
};

private void connectWebsocket() {
    disconnectWebsocket();

    if (handler != null) {
        handler.removeCallbacks(runnableCallback);
    }

    try {
        SSLContext sslContext = SSLContext.getInstance("TLS");
        sslContext.init(null, new TrustManager[] { trm }, null);
        AsyncHttpClient.getDefaultInstance().getSSLSocketMiddleware().setSSLContext(sslContext);
        AsyncHttpClient.getDefaultInstance().getSSLSocketMiddleware().setTrustManagers(new TrustManager[] {trm});
        AsyncHttpClient.getDefaultInstance().getSSLSocketMiddleware().setHostnameVerifier(SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
    }
    catch (Exception e) {
        Log.e(TAG, "Unable to set sslcontext", e);
    }

    String reqUrl = MiscUtils.buildUrl( baseUrl, "websocket/graphtools/1");
    //reqUrl = reqUrl.replace("http://", "ws://");
    //reqUrl = reqUrl.replace("https://", "wss://");
    AsyncHttpRequest request = MiscUtils.extendRequest(new AsyncHttpGet(reqUrl), authenticationInfo);
    AsyncHttpClient.getDefaultInstance().websocket(request, null, new AsyncHttpClient.WebSocketConnectCallback() {
        @Override
        public void onCompleted(Exception ex, WebSocket webSocket) {
            if (ex != null) {
                Log.e(TAG, "Unable to connect to websocket", ex);
                if (handler != null) {
                    MiscUtils.displayToast(activity, "Unable to connect to weboscket, trying to reconnect", Toast.LENGTH_SHORT);
                    handler.postDelayed(runnableCallback, 2000);
                }
                return;
            }

            Log.i(TAG, "Websocket onCompleted");
            mConnection = webSocket;

             webSocket.setStringCallback(new WebSocket.StringCallback() {
                @Override
                public void onStringAvailable(String s) {
                    Log.i(TAG, "Ws string available: " + s);
                    if (activity != null) {
                        ((WebSocketHelper) ((AuthenticationHelper) activity).getZoneFragment()).parseWebSocketEvent(s);
                    }
                }
            });
            webSocket.setEndCallback(new CompletedCallback() {
                @Override
                public void onCompleted(Exception ex) {
                    Log.i(TAG, "Websocket disconnected");
                    updateWebsocketStatusLabel(false);
                }
            });
            webSocket.setClosedCallback(new CompletedCallback() {
                @Override
                public void onCompleted(Exception ex) {
                    if (handler != null) {
                        Log.i(TAG, "Websocket closed");
                        MiscUtils.displayToast(activity, "Websocket connection lost, trying to reconnect", Toast.LENGTH_SHORT);
                        handler.postDelayed(runnableCallback, 1000);
                    }
                }
            });
            updateWebsocketStatusLabel(true);
        }
    });
}

Runnable runnableCallback = new Runnable() {
    @Override
    public void run() {
        connectWebsocket();
    }
};

有人可以告诉我这是实现此回调的正确方法吗？