1

我有一个 EJB 计时器 (EJB 2.1)，它具有 bean 托管事务。

计时器代码调用一个业务方法，该方法在单个事务中处理 2 个资源。一种是数据库，另一种是 MQ 队列服务器。

使用的应用服务器是 Websphere Application Server 7 (WAS)。为了确保跨 2 个资源（数据库和队列管理器）的一致性，我们在 WAS 中启用了支持 2 阶段提交的选项。这是为了确保在数据库操作过程中发生任何异常时，发布在队列中的消息会随着数据库回滚而回滚，反之亦然。

以下是解释的流程：

当 Timer 代码发生超时时，调用 DirectProcessor 中的 startProcess()，这是我们的业务方法。此方法有一个 try 块，其中有一个对同一类中的 createPostXMLMessage() 的方法调用。这又调用了 PostMsg 类中的另一个方法 postMessage()。

问题是当我们在 createPostXMLMessage() 方法中遇到任何数据库异常时，虽然数据库部分成功回滚，但之前发布的消息不会回滚。请帮忙。

在 ejb-jar.xml

<session id="Transmit">
    <ejb-name>Transmit</ejb-name>
    <home>com.TransmitHome</home>
    <remote>com.Transmit</remote>
    <ejb-class>com.TransmitBean</ejb-class>
    <session-type>Stateless</session-type>
    <transaction-type>Bean</transaction-type>       
</session>

public class TransmitBean implements javax.ejb.SessionBean, javax.ejb.TimedObject {
    public void ejbTimeout(Timer arg0) {
         ....

         new DIRECTProcessor().startProcess(mySessionCtx);

    }
}

public class DIRECTProcessor {

    public String startProcess(javax.ejb.SessionContext mySessionCtx) {

        ....

        UserTransaction ut= null;
        ut = mySessionCtx.getUserTransaction();

        try {
            ut.begin();
            createPostXMLMessage(interfaceObj, btch_id, dpId, errInd);
            ut.commit();
        } 

        catch (Exception e) {                      
             ut.rollback();
             ut=null;        
        }
    }

    public void createPostXMLMessage(ArrayList<InstrInterface> arr_instrObj, String batchId, String dpId,int errInd) throws Exception {
      ...

      PostMsg pm = new PostMsg();
      try {
            pm.postMessage( q_name, final_msg.toString());

           // database update operations using jdbc

      }

      catch (Exception e) {
        throw e;      
      }

    }
}

public class PostMsg {

    public String postMessage(String qName, String message) throws Exception {
        QueueConnectionFactory qcf = null;
        Queue que = null;
        QueueSession qSess = null;
        QueueConnection qConn = null;
        QueueSender qSender = null;
        que = ServiceLocator.getInstance().getQ(qName);

        try {
            qConn = (QueueConnection) qcf.createQueueConnection(
                    Constants.QCONN_USER, Constants.QCONN_PSWD);
            qSess = qConn.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);
            qSender = qSess.createSender(que);

            TextMessage txt = qSess.createTextMessage();
            txt.setJMSDestination(que);
            txt.setText(message);
            qSender.send(txt);

        } catch (Exception e) {

            retval = Constants.ERROR;
            e.printStackTrace();
            throw e;

        } finally {

            closeQSender(qSender);
            closeQSession(qSess);
            closeQConn(qConn);
        }

        return retval;

    }

}
4

0 回答 0