@Test public void shouldHandle() { assertTrue(exceptionHandler.handles(new MyException2())); assertFalse(exceptionHandler.handles(new NullPointerException())); }
@Override public boolean handles(Throwable t) { return Arrays.stream(supportedThrowables).anyMatch(th -> th.isInstance(t)); }
RetryEventDeliveryExceptionHandler implements EventDeliveryExceptionHandler { @Override public boolean handles(Throwable t) { return Arrays.stream(supportedThrowables).anyMatch(th -> th.isInstance(t)); } }
RetryEventDeliveryExceptionHandler implements EventDeliveryExceptionHandler { @Override public boolean handles(Throwable t) { return Arrays.stream(supportedThrowables).anyMatch(th -> th.isInstance(t)); } RetryEventDeliveryExceptionHandler(EventuateClientScheduler eventuateClientScheduler); }
RetryEventDeliveryExceptionHandler implements EventDeliveryExceptionHandler { @Override public boolean handles(Throwable t) { return Arrays.stream(supportedThrowables).anyMatch(th -> th.isInstance(t)); } RetryEventDeliveryExceptionHandler(EventuateClientScheduler eventuateClientScheduler); @Override boolean handles(Throwable t); @Override EventDeliveryExceptionHandlerState makeState(Throwable t); @Override void handle(EventDeliveryExceptionHandlerState state, Throwable t, Runnable retry, Consumer<Throwable> fail, Runnable ignore); @SafeVarargs final RetryEventDeliveryExceptionHandler withExceptions(Class<? extends Throwable>... throwables); RetryEventDeliveryExceptionHandler withMaxRetries(int numberOfRetries); RetryEventDeliveryExceptionHandler withInfiniteRetries(); RetryEventDeliveryExceptionHandler withRetryInterval(Duration retryInterval); }
RetryEventDeliveryExceptionHandler implements EventDeliveryExceptionHandler { @Override public boolean handles(Throwable t) { return Arrays.stream(supportedThrowables).anyMatch(th -> th.isInstance(t)); } RetryEventDeliveryExceptionHandler(EventuateClientScheduler eventuateClientScheduler); @Override boolean handles(Throwable t); @Override EventDeliveryExceptionHandlerState makeState(Throwable t); @Override void handle(EventDeliveryExceptionHandlerState state, Throwable t, Runnable retry, Consumer<Throwable> fail, Runnable ignore); @SafeVarargs final RetryEventDeliveryExceptionHandler withExceptions(Class<? extends Throwable>... throwables); RetryEventDeliveryExceptionHandler withMaxRetries(int numberOfRetries); RetryEventDeliveryExceptionHandler withInfiniteRetries(); RetryEventDeliveryExceptionHandler withRetryInterval(Duration retryInterval);  }