import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
/**
 * Executes the pipeline stage with the given pipeline context and returns the result.
 * <p>
 * Invokes the prepare method on the stage and returns the result. The stage is invoked in it's own transaction. If an exception is caught the transaction is rolled back and the stage is marked
 * as FAILED.
 * </p>
 *
 * @param pipelineContext
 *         the pipeline context
 * @param pipelineStage
 *         the pipeline stage class
 * @return a {@link PipelineStageResult}
 */
@TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
public PipelineStageResult execute(PipelineContext pipelineContext, Class<PipelineStage> pipelineStage) {
    DependentProvider<PipelineStage> dependentProvider = null;
    try {
        logBefore(pipelineContext, pipelineStage, "preparing");
        dependentProvider = BeanProvider.getDependent(pipelineStage);
        PipelineStageResult result = dependentProvider.get().prepare(pipelineContext);
        logAfter(pipelineContext, pipelineStage, result);
        return result;
    } catch (Exception e) {
        ejbContext.setRollbackOnly();

        String message = "Pipeline execution failed at stage " + pipelineStage.getName() + ". Reason " + e.getMessage();
        LOGGER.error(message, e);
        return PipelineStageResult.builder(pipelineContext.getPipelineId(), PipelineStageStatus.FAILED).addMessages(ImmutableSet.of(message)).build();
    } finally {
        if (dependentProvider != null) {
            dependentProvider.destroy();
        }
    }
}
 

import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
/**
 * Executes the pipeline stage with the given pipeline context and callback event before returning the result.
 * <p>
 * Invoke the callback method on the stage and returns the result. The stage is invoked in it's own transaction. If an exception is caught the transaction is rolled back and the stage is marked
 * as FAILED.
 * </p>
 *
 * @param pipelineContext
 *         the pipeline context
 * @param pipelineStage
 *         the pipeline stage
 * @param callbackEvent
 *         the callback event
 * @return a {@link PipelineStageResult}
 */
@TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
public PipelineStageResult onCallback(PipelineContext pipelineContext, Class<PipelineStage> pipelineStage, CallbackEvent callbackEvent) {
    DependentProvider<PipelineStage> dependentProvider = null;
    try {
        logBefore(pipelineContext, pipelineStage, "resuming");
        dependentProvider = BeanProvider.getDependent(pipelineStage);
        PipelineStageResult result = dependentProvider.get().onCallback(pipelineContext, callbackEvent);
        logAfter(pipelineContext, pipelineStage, result);
        return result;
    } catch (Exception e) {
        ejbContext.setRollbackOnly();

        String message = "Pipeline execution failed at stage " + pipelineStage.getName() + ". Reason " + e.getMessage();
        LOGGER.error(message, e);
        return PipelineStageResult.builder(pipelineContext.getPipelineId(), PipelineStageStatus.FAILED).addMessages(ImmutableSet.of(message)).build();
    } finally {
        if (dependentProvider != null) {
            dependentProvider.destroy();
        }
    }
}
 

import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
@TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
public void onFailure(PipelineContext pipelineContext, Class<PipelineFailureStage> pipelineFailureStage) {
    DependentProvider<PipelineFailureStage> dependentProvider = null;
    try {
        LOGGER.debug("executing pipeline failure stage " + pipelineFailureStage.getName());
        dependentProvider = BeanProvider.getDependent(pipelineFailureStage);
        dependentProvider.get().onFailure(pipelineContext);
        LOGGER.debug("executed pipeline failure stage " + pipelineFailureStage.getName());
    } catch (Exception e) {
        ejbContext.setRollbackOnly();
        String message = "Failed to execute pipeline failure stage " + pipelineFailureStage.getName() + ". Reason " + e.getMessage();
        LOGGER.error(message, e);

    } finally {
        if (dependentProvider != null) {
            dependentProvider.destroy();
        }
    }
}
 

import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
@Test
public void should_hit_cache() {

    CacheableService service = BeanProvider.getContextualReference(CacheableService.class);

    assertThat(service.get(1L, "1st call")).isEqualTo("1 1st call");
    assertThat(service.get(2L, "1st call")).isEqualTo("2 1st call");
    assertThat(service.get(1L, "2nd call")).isEqualTo("1 1st call");
    assertThat(service.get(1L, "3rd call")).isEqualTo("1 1st call");
    assertThat(service.get(2L, "2nd call")).isEqualTo("2 1st call");

    CallCounter callCounter = BeanProvider.getContextualReference(CallCounter.class);
    assertThat(callCounter.calls()).isEqualTo(2);

    service.removeAll();
    callCounter.reset();
}
 

import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
@Test
public void should_evict_cache() {

    CacheableService service = BeanProvider.getContextualReference(CacheableService.class);

    assertThat(service.get(1L, "1st call")).isEqualTo("1 1st call");
    assertThat(service.get(1L, "2nd call")).isEqualTo("1 1st call");
    assertThat(service.get(2L, "1st call")).isEqualTo("2 1st call");

    service.update(1L, "update");

    assertThat(service.get(1L, "3rd call")).isEqualTo("1 3rd call");
    assertThat(service.get(2L, "2nd call")).isEqualTo("2 1st call");

    CallCounter callCounter = BeanProvider.getContextualReference(CallCounter.class);
    assertThat(callCounter.calls()).isEqualTo(3);

    service.removeAll();
    callCounter.reset();
}
 

import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
@Before
public final void setUp() throws Exception {
    System.out.printf("AbstractCdiContainerTest#setUp() containerRefCount=%d, cdiContainer=%s\n", containerRefCount.get(), cdiContainer );

    if ( cdiContainer != null ) {
        containerRefCount.incrementAndGet();

        final ContextControl ctxCtrl = BeanProvider.getContextualReference(ContextControl.class);

        //stop the RequestContext to dispose of the @RequestScoped EntityManager
        ctxCtrl.stopContext(RequestScoped.class);

        //immediately restart the context again
        ctxCtrl.startContext(RequestScoped.class);

        // perform injection into the very own test class
        final BeanManager beanManager = cdiContainer.getBeanManager();
        final CreationalContext creationalContext = beanManager.createCreationalContext(null);

        final AnnotatedType annotatedType = beanManager.createAnnotatedType(this.getClass());
        final InjectionTarget injectionTarget = beanManager.createInjectionTarget(annotatedType);
        injectionTarget.inject(this, creationalContext);
    }
}
 

import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
@After
    public final void tearDown() throws Exception {
        System.out.printf("AbstractCdiContainerTest#tearDown() containerRefCount=%d, cdiContainer=%s\n", containerRefCount.get(), cdiContainer );
        if (cdiContainer != null) {
            final ContextControl ctxCtrl = BeanProvider.getContextualReference(ContextControl.class);

            //stop the RequestContext to dispose of the @RequestScoped EntityManager
            ctxCtrl.stopContext(RequestScoped.class);

            //immediately restart the context again
            ctxCtrl.startContext(RequestScoped.class);

//            cdiContainer.getContextControl().stopContext(RequestScoped.class);
//            cdiContainer.getContextControl().startContext(RequestScoped.class);
            containerRefCount.decrementAndGet();
        }
    }
 

import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
@Override
protected Object createTest() throws Exception
{
    BeanManager beanManager = BeanManagerProvider.getInstance().getBeanManager();

    Class<?> type = getTestClass().getJavaClass();
    Set<Bean<?>> beans = beanManager.getBeans(type);

    Object result;
    if (!USE_TEST_CLASS_AS_CDI_BEAN || beans == null || beans.isEmpty())
    {
        result = super.createTest();
        BeanProvider.injectFields(result); //fallback to simple injection
    }
    else
    {
        Bean<Object> bean = (Bean<Object>) beanManager.resolve(beans);
        CreationalContext<Object> creationalContext = beanManager.createCreationalContext(bean);
        result = beanManager.getReference(bean, type, creationalContext);
    }
    return result;
}
 

import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
@Override
public T produce(CreationalContext<T> creationalContext)
{
    DynamicMockManager mockManager =
        BeanProvider.getContextualReference(this.beanManager, DynamicMockManager.class, false);

    for (Type beanType : this.beanTypes)
    {
        Object mockInstance = mockManager.getMock(
            (Class)beanType, this.qualifiers.toArray(new Annotation[this.qualifiers.size()]));

        if (mockInstance != null)
        {
            return (T)mockInstance;
        }
    }

    return wrapped.produce(creationalContext);
}
 

import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
@AfterClass
public static void finalCheck()
{
    int value = BeanProvider.getContextualReference(ApplicationScopedTestBean.class).getValue();
    int nextValue = BeanProvider.getContextualReference(ApplicationScopedTestBeanClient.class).getNextValue();

    if (value == 0)
    {
        throw new IllegalStateException("new application-scoped bean instance was created");
    }

    if (nextValue == 1)
    {
        throw new IllegalStateException("new application-scoped bean instance was created");
    }
}
 

import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
@Test
public void injectionViaConfigProperty()
{
    SettingsBean settingsBean = BeanProvider.getContextualReference(SettingsBean.class, false);

    assertEquals(14, settingsBean.getProperty1());
    assertEquals(7L, settingsBean.getProperty2());
    assertEquals(-7L, settingsBean.getInverseProperty2());

    // also check the ones with defaultValue
    assertEquals("14", settingsBean.getProperty3Filled());
    assertEquals("myDefaultValue", settingsBean.getProperty3Defaulted());
    assertEquals(42, settingsBean.getProperty4Defaulted());

    assertEquals("some setting for prodDB", settingsBean.getDbConfig());
}
 

import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
@AfterClass
public static void finalCheckAndCleanup()
{
    int testCount = TestUtils.getTestMethodCount(SessionScopePerTestClassTest.class);

    if (RequestScopedBean.getInstanceCount() != testCount)
    {
        throw new IllegalStateException("unexpected instance count");
    }
    RequestScopedBean.resetInstanceCount();

    if (BeanProvider.getContextualReference(ApplicationScopedBean.class).getCount() != testCount)
    {
        throw new IllegalStateException("unexpected count");
    }

    if (BeanProvider.getContextualReference(SessionScopedBean.class).getCount() != testCount)
    {
        throw new IllegalStateException("unexpected count");
    }
    BeanProvider.getContextualReference(ApplicationScopedBean.class).resetCount();
}
 

import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
@Test
public void invocationOfMultipleSecuredStereotypes()
{
    SecuredBean4 testBean = BeanProvider.getContextualReference(SecuredBean4.class, false);

    TestAccessDecisionVoter1 voter1 = BeanProvider.getContextualReference(TestAccessDecisionVoter1.class, false);
    TestAccessDecisionVoter2 voter2 = BeanProvider.getContextualReference(TestAccessDecisionVoter2.class, false);

    Assert.assertFalse(voter1.isCalled());
    Assert.assertFalse(voter2.isCalled());

    Assert.assertEquals("result", testBean.getResult());

    Assert.assertTrue(voter1.isCalled());
    Assert.assertTrue(voter2.isCalled());
}
 

import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException
{

    /*
     * The ServletObjectInjectionBean is manually looked up using BeanProvider because not all containers may
     * support injection into servlets.
     */
    ServletObjectInjectionBean bean =
            BeanProvider.getContextualReference(ServletObjectInjectionBean.class);

    ServletOutputStream stream = resp.getOutputStream();
    logDetails(stream, "ServletRequest", bean.getServletRequest());
    logDetails(stream, "HttpServletRequest", bean.getHttpServletRequest());
    logDetails(stream, "ServletResponse", bean.getServletResponse());
    logDetails(stream, "HttpServletResponse", bean.getHttpServletResponse());
    logDetails(stream, "HttpSession", bean.getHttpSession());
    logDetails(stream, "Principal", bean.getPrincipal());

}
 

import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public void notify(final ExceptionEvent<T> event, BeanManager beanManager) throws Exception
{
    CreationalContext<?> ctx = null;
    try
    {
        ctx = beanManager.createCreationalContext(null);
        @SuppressWarnings("unchecked")
        Object handlerInstance = BeanProvider.getContextualReference(declaringBeanClass);
        InjectableMethod<?> im = createInjectableMethod(handler, getDeclaringBean(), beanManager);
        im.invoke(handlerInstance, ctx, new OutboundParameterValueRedefiner(event, this));
    }
    finally
    {
        if (ctx != null)
        {
            ctx.release();
        }
    }
}
 

import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
protected UserTransaction resolveUserTransaction()
{
    //manual lookup needed because injecting UserTransactionResolver can fail (see the comment there)
    try
    {
        DependentProvider<UserTransactionResolver> provider =
            BeanProvider.getDependent(this.beanManager, UserTransactionResolver.class);

        UserTransaction userTransaction = provider.get().resolveUserTransaction();

        provider.destroy();
        return userTransaction;
    }
    catch (Exception e)
    {
        return null;
    }
}
 

import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
private static <T> T getContextualReference(BeanManager beanManager, Class<T> type)
{
    Set<Bean<?>> beans = beanManager.getBeans(type);

    if (beans == null || beans.isEmpty())
    {
        return null;
    }

    Bean<?> bean = beanManager.resolve(beans);

    CreationalContext<?> creationalContext = beanManager.createCreationalContext(bean);

    @SuppressWarnings({ "unchecked", "UnnecessaryLocalVariable" })
    T result = (T) beanManager.getReference(bean, type, creationalContext);

    if (bean.getScope().equals(Dependent.class))
    {
        AbstractBeanStorage beanStorage = BeanProvider.getContextualReference(RequestDependentBeanStorage.class);

        //noinspection unchecked
        beanStorage.add(new DependentBeanEntry(result, bean, creationalContext));
    }

    return result;
}
 

import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
private synchronized void init()
{
    // switch into paranoia mode
    if (this.initialized == null)
    {
        if (ClassDeactivationUtils.isActivated(getClass()))
        {
            this.securityAwareViewHandler = createSecurityAwareViewHandler();
        }
        else
        {
            this.securityAwareViewHandler = null;
        }

        this.clientWindow = BeanProvider.getContextualReference(ClientWindow.class, true);
        
        this.initialized = true;
    }
}
 

import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
private synchronized void init()
{
    // switch into paranoia mode
    if (this.initialized == null)
    {
        if (ClassDeactivationUtils.isActivated(JsfRequestBroadcaster.class))
        {
            this.jsfRequestBroadcaster =
                    BeanProvider.getContextualReference(JsfRequestBroadcaster.class, true);
        }

        clientWindow = BeanProvider.getContextualReference(ClientWindow.class, true);
        windowContext = BeanProvider.getContextualReference(WindowContext.class, true);
        contextExtension = BeanProvider.getContextualReference(DeltaSpikeContextExtension.class, true);
        
        this.initialized = true;
    }
}
 

import org.apache.deltaspike.core.api.provider.BeanProvider; //导入依赖的package包/类
private void checkSecuredView(FacesContext facesContext)
{
    if (!this.securityModuleActivated)
    {
        return;
    }

    try
    {
        BeanProvider.getContextualReference(ViewRootAccessHandler.class).checkAccessTo(facesContext.getViewRoot());
    }
    catch (ErrorViewAwareAccessDeniedException accessDeniedException)
    {
        SecurityUtils.tryToHandleSecurityViolation(accessDeniedException);
        facesContext.renderResponse();
    }
}