@Test public void testRetryableExceptionWithDelay() { RetryInfo retryInfo = RetryInfo.newBuilder() .setRetryDelay(Duration.newBuilder().setSeconds(22L)) .build(); Metadata errorMetadata = new Metadata(); errorMetadata.put(ProtoUtils.keyForProto(RetryInfo.getDefaultInstance()), retryInfo); StatusRuntimeException retryableException = new StatusRuntimeException(Status.RESOURCE_EXHAUSTED, errorMetadata); assertThat(createR2dbcException(retryableException)) .isInstanceOf(R2dbcTransientResourceException.class); }
public static R2dbcException createR2dbcException(int errorCode, String message) { return createR2dbcException(errorCode, message, null); }
SpannerExceptionUtil { public static R2dbcException createR2dbcException(int errorCode, String message) { return createR2dbcException(errorCode, message, null); } }
SpannerExceptionUtil { public static R2dbcException createR2dbcException(int errorCode, String message) { return createR2dbcException(errorCode, message, null); }  }
SpannerExceptionUtil { public static R2dbcException createR2dbcException(int errorCode, String message) { return createR2dbcException(errorCode, message, null); }  static R2dbcException createR2dbcException(int errorCode, String message); static R2dbcException createR2dbcException(Throwable baseException); }
SpannerExceptionUtil { public static R2dbcException createR2dbcException(int errorCode, String message) { return createR2dbcException(errorCode, message, null); }  static R2dbcException createR2dbcException(int errorCode, String message); static R2dbcException createR2dbcException(Throwable baseException);  }