我有以下代码保存用户并发送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!
1条答案
按热度按时间rsl1atfo1#
JavaEE不支持嵌套事务。它只支持挂起事务、运行不相关的事务以及恢复第一个事务。
要实现这一点,您需要调用另一个使用requiresnew事务属性的ejb。请注意,即使消息回执回滚,内部事务也可以完成,这意味着如果消息传递引擎崩溃,第二个事务可能会再次运行。或者,您可以将ejb更改为使用bean管理的事务,这将产生类似的效果。
你确定你真的要这么做吗?最好只在容器管理的事务中执行逻辑。