类javax.ejb.MessageDrivenContext源码实例Demo

下面列出了怎么用javax.ejb.MessageDrivenContext的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: tomee   文件: ContextLookupMdbBean.java
@Override
public void lookupMessageDrivenContext() throws TestFailureException {
    try {
        try {
            final InitialContext ctx = new InitialContext();
            Assert.assertNotNull("The InitialContext is null", ctx);

            // lookup in enc
            final MessageDrivenContext sctx = (MessageDrivenContext) ctx.lookup("java:comp/env/mdbcontext");
            Assert.assertNotNull("The MessageDrivenContext got from java:comp/env/mdbcontext is null", sctx);

            // lookup using global name
            final EJBContext ejbCtx = (EJBContext) ctx.lookup("java:comp/EJBContext");
            Assert.assertNotNull("The MessageDrivenContext got from java:comp/EJBContext is null ", ejbCtx);

            // verify context was set via legacy set method
            Assert.assertNotNull("The MessageDrivenContext is null from setter method", mdbContext);
        } catch (final Exception e) {
            Assert.fail("Received Exception " + e.getClass() + " : " + e.getMessage());
        }
    } catch (final AssertionFailedError afe) {
        throw new TestFailureException(afe);
    }

}
 
源代码2 项目: tomee   文件: ContextLookupMdbPojoBean.java
public void lookupMessageDrivenContext() throws TestFailureException {
    try {
        try {
            final InitialContext ctx = new InitialContext();
            Assert.assertNotNull("The InitialContext is null", ctx);

            // lookup in enc
            final MessageDrivenContext sctx = (MessageDrivenContext) ctx.lookup("java:comp/env/mdbcontext");
            Assert.assertNotNull("The MessageDrivenContext got from java:comp/env/mdbcontext is null", sctx);

            // lookup using global name
            final EJBContext ejbCtx = (EJBContext) ctx.lookup("java:comp/EJBContext");
            Assert.assertNotNull("The MessageDrivenContext got from java:comp/EJBContext is null ", ejbCtx);
        } catch (final Exception e) {
            Assert.fail("Received Exception " + e.getClass() + " : " + e.getMessage());
        }
    } catch (final AssertionFailedError afe) {
        throw new TestFailureException(afe);
    }

}
 
源代码3 项目: tomee   文件: EncMdbBean.java
@Override
public void lookupMessageDrivenContext() throws TestFailureException {
    try {
        try {
            final InitialContext ctx = new InitialContext();
            Assert.assertNotNull("The InitialContext is null", ctx);

            // lookup in enc
            final MessageDrivenContext messageDrivenContext = (MessageDrivenContext) ctx.lookup("java:comp/env/mdbcontext");
            Assert.assertNotNull("The SessionContext got from java:comp/env/mdbcontext is null", messageDrivenContext);

            // lookup using global name
            final EJBContext ejbCtx = (EJBContext) ctx.lookup("java:comp/EJBContext");
            Assert.assertNotNull("The SessionContext got from java:comp/EJBContext is null ", ejbCtx);

            // verify context was set via legacy set method
            Assert.assertNotNull("The MdbContext is null from setter method", mdbContext);
        } catch (final Exception e) {
            Assert.fail("Received Exception " + e.getClass() + " : " + e.getMessage());
        }
    } catch (final AssertionFailedError afe) {
        throw new TestFailureException(afe);
    }

}
 
源代码4 项目: tomee   文件: ContextLookupMdbBean.java
@Override
public void setMessageDrivenContext(final MessageDrivenContext ctx) throws EJBException {
    this.mdbContext = ctx;
    try {
        final ConnectionFactory connectionFactory = (ConnectionFactory) new InitialContext().lookup("java:comp/env/jms");
        mdbInvoker = new MdbInvoker(connectionFactory, this);
    } catch (final Exception e) {
        throw new EJBException(e);
    }
}
 
源代码5 项目: tomee   文件: BasicMdbBean.java
@Override
public void setMessageDrivenContext(final MessageDrivenContext ctx) throws EJBException {
    this.mdbContext = ctx;
    testAllowedOperations("setMessageDrivenContext");
    try {
        final ConnectionFactory connectionFactory = (ConnectionFactory) new InitialContext().lookup("java:comp/env/jms");
        mdbInvoker = new MdbInvoker(connectionFactory, this);
    } catch (final Exception e) {
        throw new EJBException(e);
    }
}
 
源代码6 项目: tomee   文件: InterceptorMdbBean.java
@Override
public void setMessageDrivenContext(final MessageDrivenContext ctx) throws EJBException {
    this.mdbContext = ctx;
    try {
        mdbInvoker = new MdbInvoker(connectionFactory, this);
    } catch (final Exception e) {
        throw new EJBException(e);
    }
}
 
源代码7 项目: tomee   文件: SetterInjectionMdbBean.java
@Override
public void setMessageDrivenContext(final MessageDrivenContext ctx) throws EJBException {
    this.mdbContext = ctx;
    try {
        final ConnectionFactory connectionFactory = (ConnectionFactory) new InitialContext().lookup("java:comp/env/jms");
        mdbInvoker = new MdbInvoker(connectionFactory, this);
    } catch (final Exception e) {
        throw new EJBException(e);
    }
}
 
源代码8 项目: tomee   文件: FieldInjectionMdbBean.java
@Override
public void setMessageDrivenContext(final MessageDrivenContext ctx) throws EJBException {
    this.mdbContext = ctx;
    try {
        final ConnectionFactory connectionFactory = (ConnectionFactory) new InitialContext().lookup("java:comp/env/jms");
        mdbInvoker = new MdbInvoker(connectionFactory, this);
    } catch (final Exception e) {
        throw new EJBException(e);
    }
}
 
源代码9 项目: tomee   文件: EncMdbBean.java
@Override
public void setMessageDrivenContext(final MessageDrivenContext ctx) throws EJBException {
    this.mdbContext = ctx;
    try {
        final ConnectionFactory connectionFactory = (ConnectionFactory) new InitialContext().lookup("java:comp/env/jms");
        mdbInvoker = new MdbInvoker(connectionFactory, this);
    } catch (final Exception e) {
        throw new EJBException(e);
    }
}
 
源代码10 项目: tomee   文件: MergeWebappJndiContext.java
private <R extends JndiReference> boolean isPrivateReference(final R a) {
    if (!isResourceRef(a)) {
        return false;
    }

    final Class[] types = {EJBContext.class, EntityContext.class, SessionContext.class, MessageDrivenContext.class, UserTransaction.class};

    for (final Class type : types) {
        if (type.getName().equals(a.getType())) {
            return true;
        }
    }

    return false;
}
 
源代码11 项目: netbeans   文件: TestMDBQueueBean.java
/**
 * @see javax.ejb.MessageDrivenBean#setMessageDrivenContext(javax.ejb.MessageDrivenContext)
 */
public void setMessageDrivenContext(MessageDrivenContext aContext) {
    context = aContext;
}
 
源代码12 项目: netbeans   文件: TestMDBTopicBean.java
/**
 * @see javax.ejb.MessageDrivenBean#setMessageDrivenContext(javax.ejb.MessageDrivenContext)
 */
public void setMessageDrivenContext(MessageDrivenContext aContext) {
    context = aContext;
}
 
源代码13 项目: cxf   文件: DispatchMDBMessageListenerImpl.java
public void setMessageDrivenContext(MessageDrivenContext mdc) {
}
 
源代码14 项目: iaf   文件: CustomIfsaReceiverMDBAbstractBase.java
public MessageDrivenContext getMessageDrivenContext() {
    return ejbContext;
}
 
源代码15 项目: iaf   文件: CustomIfsaReceiverMDBAbstractBase.java
public void setMessageDrivenContext(MessageDrivenContext ctx) throws EJBException {
    ejbContext = ctx;
}
 
源代码16 项目: iaf   文件: GenericMDB.java
@Override
public void setMessageDrivenContext(MessageDrivenContext ejbContext) throws EJBException {
       log.info("Received EJB-MDB Context");
       this.ejbContext = ejbContext;
   }
 
源代码17 项目: tomee   文件: SetterInjectionMdbBean.java
public MessageDrivenContext getEjbContext() {
    return ejbContextField;
}
 
源代码18 项目: tomee   文件: SetterInjectionMdbBean.java
public void setEjbContext(final MessageDrivenContext ejbContext) {
    this.ejbContextField = ejbContext;
}
 
源代码19 项目: tomee   文件: CustomMdbContainerTest.java
@Resource
public void setMessageDrivenContext(final MessageDrivenContext messageDrivenContext) {
    lifecycle.push(Lifecycle.INJECTION);
}
 
源代码20 项目: tomee   文件: QuartzMdbContainerTest.java
@Resource
public void setMessageDrivenContext(final MessageDrivenContext messageDrivenContext) {
    lifecycle.push(Lifecycle.INJECTION);
}
 
源代码21 项目: tomee   文件: JmsMdbContainerTest.java
@Resource
public void setMessageDrivenContext(final MessageDrivenContext messageDrivenContext) {
    lifecycle.push(Lifecycle.INJECTION);
}
 
源代码22 项目: tomee   文件: NoMessageDeliveryTest.java
@Resource
public void setMessageDrivenContext(final MessageDrivenContext messageDrivenContext) {
    lifecycle.push(Lifecycle.INJECTION);
}
 
源代码23 项目: windup   文件: EJBMessageDrivenNotInEJBXML.java
public void setMessageDrivenContext(javax.ejb.MessageDrivenContext context)
{
}