ejb sessionbean中的java嵌套事务bean托管事务

ru9i0ody  于 2021-06-30  发布在  Java
关注(0)|答案(1)|浏览(371)

我有以下代码保存用户并发送jms消息。目前我正在 Package saveUserSendMessage 使用usertransaction。当事务嵌套时,我在ejb中得到一个异常。下面我该怎么做才能使嵌套事务成为可能?

@Resource(mappedName = "java:/JmsXA")
private static QueueConnectionFactory queueConnectionFactory;

@Resource(mappedName = "EjbQueueJndi")
private static Queue queueProp;

@PersistenceContext(unitName = "ejbPersistanceunit")
private EntityManager em;

@Resource
UserTransaction ut;

@Override
public boolean saveUserSendMessage(String name, String email, int age,
        boolean arg3) throws Exception {

    UserTransaction xact = ut;
    xact.begin();

    saveUser(name, email, age);
    sendMessage("Successfully saved the user");
    try {
        if (arg3)
            throw new Exception("Unsuccessfull");
        xact.commit();
    } catch (Exception e) {
        xact.rollback();
        throw e;
    }
    return true;
}

@Override
public boolean saveUser(String name, String email, int age)
        throws Exception {
    try {
        ut.begin();
        UserEntity ue = new UserEntity();
        ue.setAge(age);
        ue.setEmail(email);
        ue.setName(name);
        em.persist(ue);
        ut.commit();
    } catch (Exception e) {
        e.printStackTrace();
        throw e;
    }
    return true;
}

我得到一个例外:

15:51:04,127 ERROR [STDERR] javax.transaction.NotSupportedException: BaseTransaction.checkTransactionState - [com.arjuna
.ats.internal.jta.transaction.arjunacore.alreadyassociated] [com.arjuna.ats.internal.jta.transaction.arjunacore.alreadya
ssociated] thread is already associated with a transaction!
rsl1atfo

rsl1atfo1#

JavaEE不支持嵌套事务。它只支持挂起事务、运行不相关的事务以及恢复第一个事务。
要实现这一点,您需要调用另一个使用requiresnew事务属性的ejb。请注意,即使消息回执回滚,内部事务也可以完成,这意味着如果消息传递引擎崩溃,第二个事务可能会再次运行。或者,您可以将ejb更改为使用bean管理的事务,这将产生类似的效果。
你确定你真的要这么做吗?最好只在容器管理的事务中执行逻辑。

相关问题