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);
        }
    }
@ 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}
{