@Test public void nonImplicatingExceptionsShouldNeverBlacklist() { NOT_IMPLICATING_NODES_EXCEPTIONS.forEach(ex -> { assertFalse(handlerConservative.shouldBlacklist(ex, MAX_RETRIES_PER_HOST + 1)); assertFalse(handlerLegacy.shouldBlacklist(ex, MAX_RETRIES_PER_HOST + 1)); }); }
@VisibleForTesting boolean shouldBlacklist(Exception ex, int numberOfAttempts) { return isConnectionException(ex) && numberOfAttempts >= maxTriesSameHost.get() && !isExceptionNotImplicatingThisParticularNode(ex); }
CassandraRequestExceptionHandler { @VisibleForTesting boolean shouldBlacklist(Exception ex, int numberOfAttempts) { return isConnectionException(ex) && numberOfAttempts >= maxTriesSameHost.get() && !isExceptionNotImplicatingThisParticularNode(ex); } }
CassandraRequestExceptionHandler { @VisibleForTesting boolean shouldBlacklist(Exception ex, int numberOfAttempts) { return isConnectionException(ex) && numberOfAttempts >= maxTriesSameHost.get() && !isExceptionNotImplicatingThisParticularNode(ex); } CassandraRequestExceptionHandler(
            Supplier<Integer> maxTriesSameHost,
            Supplier<Integer> maxTriesTotal,
            Supplier<Boolean> useConservativeHandler,
            Blacklist blacklist); private  CassandraRequestExceptionHandler(
            Supplier<Integer> maxTriesSameHost,
            Supplier<Integer> maxTriesTotal,
            Blacklist blacklist); }
CassandraRequestExceptionHandler { @VisibleForTesting boolean shouldBlacklist(Exception ex, int numberOfAttempts) { return isConnectionException(ex) && numberOfAttempts >= maxTriesSameHost.get() && !isExceptionNotImplicatingThisParticularNode(ex); } CassandraRequestExceptionHandler(
            Supplier<Integer> maxTriesSameHost,
            Supplier<Integer> maxTriesTotal,
            Supplier<Boolean> useConservativeHandler,
            Blacklist blacklist); private  CassandraRequestExceptionHandler(
            Supplier<Integer> maxTriesSameHost,
            Supplier<Integer> maxTriesTotal,
            Blacklist blacklist);  }
CassandraRequestExceptionHandler { @VisibleForTesting boolean shouldBlacklist(Exception ex, int numberOfAttempts) { return isConnectionException(ex) && numberOfAttempts >= maxTriesSameHost.get() && !isExceptionNotImplicatingThisParticularNode(ex); } CassandraRequestExceptionHandler(
            Supplier<Integer> maxTriesSameHost,
            Supplier<Integer> maxTriesTotal,
            Supplier<Boolean> useConservativeHandler,
            Blacklist blacklist); private  CassandraRequestExceptionHandler(
            Supplier<Integer> maxTriesSameHost,
            Supplier<Integer> maxTriesTotal,
            Blacklist blacklist);   }