/**
 * Socket connection callback
 *
 * @param ex     potential exception if error
 * @param client socket client
 */
@Override
public void onConnectCompleted(final Exception ex, final SocketIOClient client) {

    handler.post(new Runnable() {
        @Override
        public void run() {
            if (ex != null) {
                postError();
                return;
            }

            ioState = IOState.CONNECTED;

            socketIOClient = client;
            socketIOClient.setErrorCallback(ChatService.this);
            socketIOClient.setDisconnectCallback(ChatService.this);
            socketIOClient.addListener(ChatService.this);

            showForeground();

            post();
        }
    });
}
 

public void connect(Context context, ConnectCallback callback) {
    SocketIOClient.connect(
            PreferencesHelper.getBaseUrl(context), callback, new Handler());
}
 

public void disconnect(SocketIOClient client) {
    client.disconnect();
}