Class RetryEmitsTest

core/src/test/java/feign/LoggerTest.java:446–505

  }

  public static class RetryEmitsTest extends LoggerTest {

    private Level logLevel;

    public void initRetryEmitsTest(Level logLevel, List<String> expectedMessages) {
      this.logLevel = logLevel;
      logger.expectMessages(expectedMessages);
    }

    public static Iterable<Object[]> data() {
      return Arrays.asList(
          new Object[][] {
            {Level.NONE, Collections.emptyList()},
            {
              Level.BASIC,
              Arrays.asList(
                  "\\[SendsStuff#login\\] ---> POST http://non-exist.invalid/ HTTP/1.1",
                  "\\[SendsStuff#login\\] <--- ERROR UnknownHostException: non-exist.invalid"
                      + " \\([0-9]+ms\\)",
                  "\\[SendsStuff#login\\] ---> RETRYING",
                  "\\[SendsStuff#login\\] ---> POST http://non-exist.invalid/ HTTP/1.1",
                  "\\[SendsStuff#login\\] <--- ERROR UnknownHostException: non-exist.invalid"
                      + " \\([0-9]+ms\\)")
            }
          });
    }

    @MethodSource("data")
    @ParameterizedTest
    void retryEmits(Level logLevel, List<String> expectedMessages) {

      initRetryEmitsTest(logLevel, expectedMessages);

      SendsStuff api =
          Feign.builder()
              .logger(logger)
              .logLevel(logLevel)
              .retryer(
                  new Retryer() {
                    boolean retried;

                    @Override
                    public void continueOrPropagate(RetryableException e) {
                      if (!retried) {
                        retried = true;
                        return;
                      }
                      throw e;
                    }

                    @Override
                    public Retryer clone() {
                      return this;
                    }
                  })
              .target(SendsStuff.class, "http://non-exist.invalid");

      assertThrows(FeignException.class, () -> api.login("netflix", "denominator", "password"));