import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
private void invoke(
        final T t,
        final Class<?> c,
        final Class<? extends Annotation> annotation,
        final InterceptionType interceptionType
) {
    final Set<Method> candidates = stream(c.getDeclaredMethods())
            .filter(it -> it.getAnnotation(annotation) != null)
            .collect(toSet());
    if (candidates.isEmpty()) {
        return;
    }
    if (candidates.size() > 1) {
        throw new TestEEfiException("Only one @" + annotation.getSimpleName() + " method is allowed per class");
    }
    // TODO check for correct modifiers etc.
    final Method method = candidates.iterator().next();
    method.setAccessible(true);
    try {
        invokeIntercepted(new Object[]{}, t, method, interceptionType);
    } catch (final Throwable e) {
        throw new TestEEfiException("Failed to invoke @" + annotation.getSimpleName() + " method " + method, e);
    }
}
 

import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
private InterceptorData createInterceptorData(final Interceptor<?> i) {
    final InterceptorData data;
    if (CdiInterceptorBean.class.isInstance(i)) {
        final CdiInterceptorBean cdiInterceptorBean = CdiInterceptorBean.class.cast(i);

        data = new InterceptorData(i.getBeanClass());
        data.getAroundInvoke().addAll(getInterceptionMethodAsListOrEmpty(cdiInterceptorBean, InterceptionType.AROUND_INVOKE));
        data.getPostConstruct().addAll(getInterceptionMethodAsListOrEmpty(cdiInterceptorBean, InterceptionType.POST_CONSTRUCT));
        data.getPreDestroy().addAll(getInterceptionMethodAsListOrEmpty(cdiInterceptorBean, InterceptionType.PRE_DESTROY));
        data.getPostActivate().addAll(getInterceptionMethodAsListOrEmpty(cdiInterceptorBean, InterceptionType.POST_ACTIVATE));
        data.getPrePassivate().addAll(getInterceptionMethodAsListOrEmpty(cdiInterceptorBean, InterceptionType.PRE_PASSIVATE));
        data.getAroundTimeout().addAll(getInterceptionMethodAsListOrEmpty(cdiInterceptorBean, InterceptionType.AROUND_TIMEOUT));
        /*
        AfterBegin, BeforeCompletion and AfterCompletion are ignored since not handled by CDI
         */
    } else { // TODO: here we are not as good as in previous since we loose inheritance for instance
        data = InterceptorData.scan(i.getBeanClass());
    }
    return data;
}
 

import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
public InterceptorChain getInterceptorChain(
        final ContextFactory contextFactory
) {
    return new InterceptorChain() {
        @Override
        public <T> Object invoke(
                final Object target,
                final Method method,
                final Object[] args,
                final ChainEnd<T> next,
                final InterceptionType interceptionType
        ) throws Throwable {
            if (interceptorBindings == null) {
                return next.invoke();
            }
            return processInterceptorChain(
                    new ArrayList<>(interceptorBindings.getAllInterceptors()),
                    target,
                    method,
                    args,
                    contextFactory,
                    next,
                    interceptionType
            );
        }
    };
}
 

import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private <T> Object processInterceptorChain(
        final List<Interceptor<?>> chain,
        final Object target,
        final Method method,
        final Object[] args,
        final ContextFactory contextFactory,
        final InterceptorChain.ChainEnd<T> next,
        final InterceptionType interceptionType
) throws Throwable {
    if (chain.isEmpty()) {
        return next.invoke();
    }
    final Interceptor<Object> it = (Interceptor<Object>) chain.remove(0);
    final Releaser releaser = new Releaser();
    try {
        return intercept(
                it,
                it.create(contextFactory.create(it, releaser)),
                target,
                method,
                args,
                () -> processInterceptorChain(chain, target, method, args, contextFactory, next, interceptionType),
                interceptionType
        );
    } finally {
        releaser.release();
    }
}
 

import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
private <T> Object intercept(
        final Interceptor<T> it,
        final T instance,
        final Object target,
        final Method method,
        final Object[] args,
        final Proceed proceed,
        final InterceptionType interceptionType
) throws Exception {
    return it.intercept(
            interceptionType,
            instance,
            context(target, interceptionType == InterceptionType.AROUND_INVOKE ? method : null, args, proceed)
    );
}
 

import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
<T> Object invoke(
        Object target,
        Method method,
        Object[] args,
        ChainEnd<T> next,
        InterceptionType interceptionType
) throws Throwable;
 

import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
private Object invokeIntercepted(
        final Object[] args,
        final T target,
        final Method method,
        final InterceptionType interceptionType
) throws Throwable {
    return chain.invoke(target, method, args,
            () -> {
                try {
                    return method.invoke(target, args);
                } catch (final InvocationTargetException e) {
                    throw e.getTargetException();
                }
            }, interceptionType);
}
 

import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
@Override
public List<Interceptor<?>> resolveInterceptors(final InterceptionType type, final Annotation... interceptorBindings) {
    final List<Interceptor<?>> interceptors = super.resolveInterceptors(type, interceptorBindings);
    final List<Interceptor<?>> parentInterceptors = getParentBm().resolveInterceptors(type, interceptorBindings);
    for (final Interceptor<?> i : parentInterceptors) {
        if (!interceptors.contains(i)) {
            interceptors.add(i);
        }
    }
    return interceptors;
}
 

import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
private List<Interceptor<?>> resolveInterceptors(Object instance, Method method)
{
    BeanManager beanManager = BeanManagerProvider.getInstance().getBeanManager();
    
    Annotation[] interceptorBindings = extractInterceptorBindings(beanManager, instance, method);
    if (interceptorBindings.length > 0)
    {
        return beanManager.resolveInterceptors(InterceptionType.AROUND_INVOKE, interceptorBindings);
    }

    return new ArrayList<Interceptor<?>>();
}
 

import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
@Test
public void testDisabledInterceptor() {
    List<Interceptor<?>> interceptors = weld.getBeanManager().resolveInterceptors(InterceptionType.AROUND_INVOKE, FooBinding.Literal.INSTANCE);
    assertEquals(1, interceptors.size());
    assertEquals(MockInterceptor.class, interceptors.get(0).getBeanClass());
}
 

import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
@Override
public boolean intercepts(InterceptionType type) {
    return this.type.equals(type);
}
 

import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
@Override
public Object intercept(InterceptionType type, MockInterceptorInstance instance, InvocationContext ctx) throws Exception {
    return callback.invoke(ctx, instance.getInterceptedBean());
}
 

import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
public MockInterceptor aroundInvoke(InterceptionCallback callback) {
    return type(InterceptionType.AROUND_INVOKE).callback(callback).build();
}
 

import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
public MockInterceptor aroundConstruct(InterceptionCallback callback) {
    return type(InterceptionType.AROUND_CONSTRUCT).callback(callback).build();
}
 

import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
public MockInterceptor postConstruct(InterceptionCallback callback) {
    return type(InterceptionType.POST_CONSTRUCT).callback(callback).build();
}
 

import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
public MockInterceptor preDestroy(InterceptionCallback callback) {
    return type(InterceptionType.PRE_DESTROY).callback(callback).build();
}
 

import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
@Override
public List<Interceptor<?>> resolveInterceptors(InterceptionType type, Annotation... interceptorBindings)
{
    // TODO Auto-generated method stub
    return null;
}
 

import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
@Override
public List<Interceptor<?>> resolveInterceptors(
        final InterceptionType arg0, final Annotation... arg1) {
    return this.beanManager.resolveInterceptors(arg0, arg1);
}
 

import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
private List<Method> getInterceptionMethodAsListOrEmpty(final CdiInterceptorBean cdiInterceptorBean, final InterceptionType aroundInvoke) {
    final Method[] methods = cdiInterceptorBean.getInterceptorMethods(aroundInvoke);
    return methods == null ? Collections.<Method>emptyList() : asList(methods);
}
 

import javax.enterprise.inject.spi.InterceptionType; //导入依赖的package包/类
/**
 *
 * @param beanClass
 * @param type
 * @param callback
 * @param interceptorBindings
 */
private MockInterceptor(Class<?> beanClass, InterceptionType type, InterceptionCallback callback, Set<Annotation> interceptorBindings) {
    this.beanClass = beanClass;
    this.type = type;
    this.callback = callback;
    this.interceptorBindings = interceptorBindings;
}