src/main/java/com/github/ddth/cql/utils/RetryFutureCallbackResultSet.java
@Override
    public void onFailure(Throwable t) {
        if (t instanceof ExceedMaxAsyncJobsException) {
            try {
                if (stm != null) {
                    sessionManager.executeAsync(this, permitTimeoutMs, stm, consistencyLevel);
                } else if (pstm != null) {
                    if (bindValuesArr != null) {
                        sessionManager.executeAsync(this, permitTimeoutMs, pstm, consistencyLevel,
                                bindValuesArr);
                    } else {
                        sessionManager.executeAsync(this, permitTimeoutMs, pstm, consistencyLevel,
                                bindValuesMap);
                    }
                } else if (!StringUtils.isBlank(cql)) {
                    if (bindValuesArr != null) {
                        sessionManager.executeAsync(this, permitTimeoutMs, cql, consistencyLevel,
                                bindValuesArr);
                    } else {
                        sessionManager.executeAsync(this, permitTimeoutMs, cql, consistencyLevel,
                                bindValuesMap);
                    }
                } else {
                    onError(new Exception("No query is defined to retry!"));
                }
            } catch (Throwable _t) {
                onError(_t);
            }
        } else {
            onError(t);
        }
    }
@Override
    public void onFailure(Throwable t) {
        if (t instanceof ExceedMaxAsyncJobsException) {
            try {
                if (stm != null) {
                    sessionManager.executeAsync(this, permitTimeoutMs, stm, consistencyLevel);
                } else if (pstm != null) {
                    if (bindValuesArr != null) {
                        sessionManager.executeAsync(this, permitTimeoutMs, pstm, consistencyLevel,
                                bindValuesArr);
                    } else {
                        sessionManager.executeAsync(this, permitTimeoutMs, pstm, consistencyLevel,
                                bindValuesMap);
                    }
                } else if (!StringUtils.isBlank(cql)) {
                    if (bindValuesArr != null) {
                        sessionManager.executeAsync(this, permitTimeoutMs, cql, consistencyLevel,
                                bindValuesArr);
                    } else {
                        sessionManager.executeAsync(this, permitTimeoutMs, cql, consistencyLevel,
                                bindValuesMap);
                    }
                } else {
                    onError(new Exception("No query is defined to retry!"));
                }
            } catch (Throwable _t) {
                onError(_t);
            }
        } else {
            onError(t);
        }
    }
{@inheritDoc}