Add @priority

Author: mercyblitz

projects/stage-1/middleware-frameworks/my-fault-tolerance/src/main/java/org/geektimes/microprofile/faulttolerance/AsynchronousInterceptor.java

@@ -21,12 +21,15 @@
 import org.geektimes.commons.function.ThrowableSupplier;
 import org.geektimes.interceptor.AnnotatedInterceptor;
 
+import javax.annotation.Priority;
 import javax.interceptor.Interceptor;
 import javax.interceptor.InvocationContext;
 import java.lang.reflect.Method;
 import java.util.concurrent.*;
 
 import static java.util.concurrent.CompletableFuture.supplyAsync;
+import static org.geektimes.microprofile.faulttolerance.AsynchronousInterceptor.ASYNCHRONOUS_PRIORITY;
+import static org.geektimes.microprofile.faulttolerance.TimeoutInterceptor.TIMEOUT_PRIORITY;
 
 /**
  * The interceptor implementation for the annotation {@link Asynchronous} of
@@ -37,14 +40,16 @@
  */
 @Asynchronous
 @Interceptor
+@Priority(ASYNCHRONOUS_PRIORITY)
 public class AsynchronousInterceptor extends AnnotatedInterceptor<Asynchronous> {
 
+    public static final int ASYNCHRONOUS_PRIORITY = TIMEOUT_PRIORITY + 100;
+
     // TODO ExecutorService fixed size = external Server Thread numbers
     private final ExecutorService executor = ForkJoinPool.commonPool();
 
     public AsynchronousInterceptor() {
         super();
-        setPriority(500);
     }
 
     @Override

projects/stage-1/middleware-frameworks/my-fault-tolerance/src/main/java/org/geektimes/microprofile/faulttolerance/BulkheadInterceptor.java

@@ -21,13 +21,16 @@
 import org.eclipse.microprofile.faulttolerance.exceptions.BulkheadException;
 import org.geektimes.interceptor.AnnotatedInterceptor;
 
+import javax.annotation.Priority;
 import javax.interceptor.Interceptor;
 import javax.interceptor.InvocationContext;
 import java.lang.reflect.Method;
 import java.util.concurrent.*;
 import java.util.concurrent.atomic.AtomicInteger;
 
 import static java.lang.String.format;
+import static org.geektimes.microprofile.faulttolerance.BulkheadInterceptor.BULKHEAD_PRIORITY;
+import static org.geektimes.microprofile.faulttolerance.CircuitBreakerInterceptor.CIRCUIT_BREAKER_PRIORITY;
 
 /**
  * The interceptor implementation for the annotation {@link Bulkhead} of
@@ -38,15 +41,17 @@
  */
 @Bulkhead
 @Interceptor
+@Priority(BULKHEAD_PRIORITY)
 public class BulkheadInterceptor extends AnnotatedInterceptor<Bulkhead> {
 
+    public static final int BULKHEAD_PRIORITY = CIRCUIT_BREAKER_PRIORITY + 100;
+
     private final ConcurrentMap<Bulkhead, ExecutorService> executorsCache = new ConcurrentHashMap<>();
 
     private final ConcurrentHashMap<Bulkhead, Semaphore> semaphoresCache = new ConcurrentHashMap<>();
 
     public BulkheadInterceptor() {
         super();
-        setPriority(100);
     }
 
     @Override

projects/stage-1/middleware-frameworks/my-fault-tolerance/src/main/java/org/geektimes/microprofile/faulttolerance/CircuitBreakerInterceptor.java

@@ -21,6 +21,7 @@
 import org.geektimes.commons.util.TimeUtils;
 import org.geektimes.interceptor.AnnotatedInterceptor;
 
+import javax.annotation.Priority;
 import javax.interceptor.Interceptor;
 import javax.interceptor.InvocationContext;
 import java.util.Arrays;
@@ -29,7 +30,9 @@
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.LongAdder;
 
+import static javax.interceptor.Interceptor.Priority.LIBRARY_BEFORE;
 import static org.geektimes.commons.reflect.util.ClassUtils.isDerived;
+import static org.geektimes.microprofile.faulttolerance.CircuitBreakerInterceptor.CIRCUIT_BREAKER_PRIORITY;
 
 /**
  * The interceptor implementation for the annotation {@link CircuitBreaker} of
@@ -40,13 +43,15 @@
  */
 @CircuitBreaker
 @Interceptor
+@Priority(CIRCUIT_BREAKER_PRIORITY)
 public class CircuitBreakerInterceptor extends AnnotatedInterceptor<CircuitBreaker> {
 
+    public static final int CIRCUIT_BREAKER_PRIORITY = LIBRARY_BEFORE + 100;
+
     private final ConcurrentMap<CircuitBreaker, CountableSlidingWindow> slidingWindowsCache = new ConcurrentHashMap<>();
 
     public CircuitBreakerInterceptor() {
         super();
-        setPriority(0);
     }
 
     @Override

projects/stage-1/middleware-frameworks/my-fault-tolerance/src/main/java/org/geektimes/microprofile/faulttolerance/FallbackInterceptor.java

@@ -22,13 +22,16 @@
 import org.eclipse.microprofile.faulttolerance.exceptions.FaultToleranceDefinitionException;
 import org.geektimes.interceptor.AnnotatedInterceptor;
 
+import javax.annotation.Priority;
 import javax.interceptor.Interceptor;
 import javax.interceptor.InvocationContext;
 import java.lang.reflect.Method;
 
 import static java.lang.String.format;
 import static org.geektimes.commons.reflect.util.ClassUtils.getTypes;
 import static org.geektimes.commons.reflect.util.ClassUtils.isDerived;
+import static org.geektimes.microprofile.faulttolerance.BulkheadInterceptor.BULKHEAD_PRIORITY;
+import static org.geektimes.microprofile.faulttolerance.FallbackInterceptor.FALLBACK_PRIORITY;
 
 /**
  * The interceptor implementation for the annotation {@link Fallback} of
@@ -38,11 +41,13 @@
  * @since 1.0.0
  */
 @Interceptor
+@Priority(FALLBACK_PRIORITY)
 public class FallbackInterceptor extends AnnotatedInterceptor<Fallback> {
 
+    public static final int FALLBACK_PRIORITY = BULKHEAD_PRIORITY + 100;
+
     public FallbackInterceptor() {
         super();
-        setPriority(200);
     }
 
     @Override

projects/stage-1/middleware-frameworks/my-fault-tolerance/src/main/java/org/geektimes/microprofile/faulttolerance/RetryInterceptor.java

@@ -19,6 +19,7 @@
 import org.eclipse.microprofile.faulttolerance.Retry;
 import org.geektimes.interceptor.AnnotatedInterceptor;
 
+import javax.annotation.Priority;
 import javax.interceptor.Interceptor;
 import javax.interceptor.InvocationContext;
 import java.util.Optional;
@@ -28,8 +29,12 @@
 import static java.util.Optional.empty;
 import static java.util.Optional.of;
 import static java.util.concurrent.Executors.newScheduledThreadPool;
+import static javax.interceptor.Interceptor.Priority.LIBRARY_BEFORE;
 import static org.geektimes.commons.reflect.util.ClassUtils.isDerived;
 import static org.geektimes.commons.util.TimeUtils.toTimeUnit;
+import static org.geektimes.microprofile.faulttolerance.BulkheadInterceptor.BULKHEAD_PRIORITY;
+import static org.geektimes.microprofile.faulttolerance.FallbackInterceptor.FALLBACK_PRIORITY;
+import static org.geektimes.microprofile.faulttolerance.RetryInterceptor.RETRY_PRIORITY;
 
 /**
  * The interceptor implementation for the annotation {@link Retry} of
@@ -40,14 +45,16 @@
  */
 @Retry
 @Interceptor
+@Priority(RETRY_PRIORITY)
 public class RetryInterceptor extends AnnotatedInterceptor<Retry> {
 
+    public static final int RETRY_PRIORITY = FALLBACK_PRIORITY + 100;
+
     private final ScheduledExecutorService executorService = newScheduledThreadPool(2);
 
 
     public RetryInterceptor() {
         super();
-        setPriority(300);
     }
 
     @Override

projects/stage-1/middleware-frameworks/my-fault-tolerance/src/main/java/org/geektimes/microprofile/faulttolerance/TimeoutInterceptor.java

@@ -19,12 +19,15 @@
 import org.eclipse.microprofile.faulttolerance.Timeout;
 import org.geektimes.interceptor.AnnotatedInterceptor;
 
+import javax.annotation.Priority;
 import javax.interceptor.Interceptor;
 import javax.interceptor.InvocationContext;
 import java.time.temporal.ChronoUnit;
 import java.util.concurrent.*;
 
 import static org.geektimes.commons.util.TimeUtils.toTimeUnit;
+import static org.geektimes.microprofile.faulttolerance.RetryInterceptor.RETRY_PRIORITY;
+import static org.geektimes.microprofile.faulttolerance.TimeoutInterceptor.TIMEOUT_PRIORITY;
 
 /**
  * The interceptor implementation for the annotation {@link Timeout} of
@@ -35,14 +38,16 @@
  */
 @Timeout
 @Interceptor
+@Priority(TIMEOUT_PRIORITY)
 public class TimeoutInterceptor extends AnnotatedInterceptor<Timeout> {
 
+    public static final int TIMEOUT_PRIORITY = RETRY_PRIORITY + 100;
+
     // TODO ExecutorService fixed size = external Server Thread numbers
     private final ExecutorService executor = ForkJoinPool.commonPool();
 
     public TimeoutInterceptor() {
         super();
-        setPriority(400);
     }
 
     @Override