2

我正在开发一个应用程序,它启动一个事务,注册一些资源,启动另一个事务并根据先前事务注册的资源执行处理。例子是:

登记:

@Stateless
@LocalBean
public class Register {
    @Resource TransactionSynchronizationRegistry tsr;
    public void registerResource(String id, Resource r) {
        tsr.putResource(id, r);
    }
}

第一笔交易

@Stateless
@LocalBean
public class FirstTransaction {
    @Inject Register r;
    @Inject SecondTransaction st;

    public void doRegistering(Resource r) {
        r.registerResource("key", r);
        st.doProcess();
        // do other operations...
    }
}

第二笔交易

@Stateless
@LocalBean
public class SecondTransaction {
    @Resource TransactionSynchronizationRegistry tsr;

    /*
     * start new transaction in order to ensure that
     * there won't be any rollback on any operations
     * performed by this method if its caller fails
     */
    @TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
    public void doProcess() {
        Resource r = (Resource) tsr.getResource("key");
        // start processing resource...
    }
}

但是,由于在注册资源后创建了一个新事务,我无法再次访问相同的 TransactionSynchronizationRegistry。我知道 TransactionSynchronizationRegistry 仅用于一个事务,所以问题是是否有另一种方法,例如资源注册表,我可以在不同的事务中使用它。

谢谢。

大号

4

1 回答 1

0

这是相当多的开销,但您可以让它们从 JMS 消息队列中生成/使用有效负载。

于 2012-10-17T09:22:21.493 回答