Package io.micronaut.retry.intercept
Class DefaultRetryInterceptor
- java.lang.Object
-
- io.micronaut.retry.intercept.DefaultRetryInterceptor
-
- All Implemented Interfaces:
io.micronaut.aop.Interceptor<java.lang.Object,java.lang.Object>,io.micronaut.aop.MethodInterceptor<java.lang.Object,java.lang.Object>,io.micronaut.core.order.Ordered
@Singleton public class DefaultRetryInterceptor extends java.lang.Object implements io.micronaut.aop.MethodInterceptor<java.lang.Object,java.lang.Object>AMethodInterceptorthat retries an operation according to the specifiedRetryableannotation.- Since:
- 1.0
-
-
Constructor Summary
Constructors Constructor Description DefaultRetryInterceptor(io.micronaut.context.event.ApplicationEventPublisher eventPublisher, java.util.concurrent.ExecutorService executorService)Construct a default retry method interceptor with the event publisher.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description intgetOrder()java.lang.Objectintercept(io.micronaut.aop.MethodInvocationContext<java.lang.Object,java.lang.Object> context)
-
-
-
Constructor Detail
-
DefaultRetryInterceptor
public DefaultRetryInterceptor(io.micronaut.context.event.ApplicationEventPublisher eventPublisher, @Named("scheduled") java.util.concurrent.ExecutorService executorService)Construct a default retry method interceptor with the event publisher.- Parameters:
eventPublisher- The event publisher to publish retry eventsexecutorService- The executor service to use for completable futures
-
-
Method Detail
-
getOrder
public int getOrder()
- Specified by:
getOrderin interfaceio.micronaut.core.order.Ordered
-
intercept
@Nullable public java.lang.Object intercept(io.micronaut.aop.MethodInvocationContext<java.lang.Object,java.lang.Object> context)
- Specified by:
interceptin interfaceio.micronaut.aop.MethodInterceptor<java.lang.Object,java.lang.Object>
-
-