@Test public void isConsumerStreamRetryable() { for (Map.Entry<Throwable, Boolean> e : CODES_TO_EXCEPTIONS.entrySet()) { assertTrue(e.getValue() == ExceptionSupport.isConsumerStreamRetryable(e.getKey())); } }
static boolean isConsumerStreamRetryable(Throwable e) { if (e instanceof Error) { logger.error(String.format("non_retryable_error_class_consumer %s %s", e.getClass(), e.getMessage()), e); return false; } if (nonRetryableException(e)) { logger.error(String.format("non_retryable_exception %s %s", e.getClass(), e.getMessage()), e); return false; } if (e instanceof NonRetryableNakadiException) { logger.error(String.format("non_retryable_nakadi_exception_consumer %s %s", e.getClass(), e.getMessage()), e); return false; } if (e instanceof NotFoundException) { logger.error(String.format("non_retryable_not_found_exception_consumer %s %s", e.getClass(), e.getMessage()), e); return false; } logger.info(String.format("retryable_exception_consumer %s %s", e.getClass(), e.getMessage())); return true; }
ExceptionSupport { static boolean isConsumerStreamRetryable(Throwable e) { if (e instanceof Error) { logger.error(String.format("non_retryable_error_class_consumer %s %s", e.getClass(), e.getMessage()), e); return false; } if (nonRetryableException(e)) { logger.error(String.format("non_retryable_exception %s %s", e.getClass(), e.getMessage()), e); return false; } if (e instanceof NonRetryableNakadiException) { logger.error(String.format("non_retryable_nakadi_exception_consumer %s %s", e.getClass(), e.getMessage()), e); return false; } if (e instanceof NotFoundException) { logger.error(String.format("non_retryable_not_found_exception_consumer %s %s", e.getClass(), e.getMessage()), e); return false; } logger.info(String.format("retryable_exception_consumer %s %s", e.getClass(), e.getMessage())); return true; } }
ExceptionSupport { static boolean isConsumerStreamRetryable(Throwable e) { if (e instanceof Error) { logger.error(String.format("non_retryable_error_class_consumer %s %s", e.getClass(), e.getMessage()), e); return false; } if (nonRetryableException(e)) { logger.error(String.format("non_retryable_exception %s %s", e.getClass(), e.getMessage()), e); return false; } if (e instanceof NonRetryableNakadiException) { logger.error(String.format("non_retryable_nakadi_exception_consumer %s %s", e.getClass(), e.getMessage()), e); return false; } if (e instanceof NotFoundException) { logger.error(String.format("non_retryable_not_found_exception_consumer %s %s", e.getClass(), e.getMessage()), e); return false; } logger.info(String.format("retryable_exception_consumer %s %s", e.getClass(), e.getMessage())); return true; }  }
ExceptionSupport { static boolean isConsumerStreamRetryable(Throwable e) { if (e instanceof Error) { logger.error(String.format("non_retryable_error_class_consumer %s %s", e.getClass(), e.getMessage()), e); return false; } if (nonRetryableException(e)) { logger.error(String.format("non_retryable_exception %s %s", e.getClass(), e.getMessage()), e); return false; } if (e instanceof NonRetryableNakadiException) { logger.error(String.format("non_retryable_nakadi_exception_consumer %s %s", e.getClass(), e.getMessage()), e); return false; } if (e instanceof NotFoundException) { logger.error(String.format("non_retryable_not_found_exception_consumer %s %s", e.getClass(), e.getMessage()), e); return false; } logger.info(String.format("retryable_exception_consumer %s %s", e.getClass(), e.getMessage())); return true; }   }
ExceptionSupport { static boolean isConsumerStreamRetryable(Throwable e) { if (e instanceof Error) { logger.error(String.format("non_retryable_error_class_consumer %s %s", e.getClass(), e.getMessage()), e); return false; } if (nonRetryableException(e)) { logger.error(String.format("non_retryable_exception %s %s", e.getClass(), e.getMessage()), e); return false; } if (e instanceof NonRetryableNakadiException) { logger.error(String.format("non_retryable_nakadi_exception_consumer %s %s", e.getClass(), e.getMessage()), e); return false; } if (e instanceof NotFoundException) { logger.error(String.format("non_retryable_not_found_exception_consumer %s %s", e.getClass(), e.getMessage()), e); return false; } logger.info(String.format("retryable_exception_consumer %s %s", e.getClass(), e.getMessage())); return true; }    }