diff --git a/feign-reactor-core/src/main/java/reactivefeign/retry/FilteredReactiveRetryPolicy.java b/feign-reactor-core/src/main/java/reactivefeign/retry/FilteredReactiveRetryPolicy.java index f81767be..be114fca 100644 --- a/feign-reactor-core/src/main/java/reactivefeign/retry/FilteredReactiveRetryPolicy.java +++ b/feign-reactor-core/src/main/java/reactivefeign/retry/FilteredReactiveRetryPolicy.java @@ -1,12 +1,11 @@ package reactivefeign.retry; +import feign.ExceptionPropagationPolicy; import org.reactivestreams.Publisher; import reactor.core.Exceptions; import reactor.core.publisher.Flux; -import reactor.core.publisher.Mono; import reactor.util.retry.Retry; -import java.util.function.Function; import java.util.function.Predicate; import java.util.stream.Stream; @@ -52,4 +51,9 @@ public Publisher generateCompanion(Flux retrySignals) { } }; } + + @Override + public ExceptionPropagationPolicy exceptionPropagationPolicy(){ + return retryPolicy.exceptionPropagationPolicy(); + } }