Package com.sun.messaging.jmq.jmsserver.data.handlers

Examples of com.sun.messaging.jmq.jmsserver.data.handlers.TransactionHandler.doCommit()

190
191
192
193
194
195
196
197
198
199
200
                  if ( DEBUG ) {
                            logger.log(Logger.DEBUG,
                                "Committing " + tid + " in state " + ts);
                        }
                        try {
                            thandler.doCommit(tid, xid,
                                new Integer(XAResource.TMNOFLAGS), ts, null,
                            false, con, null);
                        } catch (BrokerException e) {
                            status = Status.ERROR;
                            errMsg = e.getMessage();
View Full Code Here
213
214
215
216
217
218
219
220
221
222
223
      }

      if (rollback)  {
          thandler.doRollback(tid, xid, null, ts, null, null, RollbackReason.ADMIN);
      } else  {
    thandler.doCommit(tid, xid, new Integer(XAResource.TMNOFLAGS), ts, null,
        false, null, null);
      }
  } catch(Exception e)  {
      String opName;
      if (rollback)  {
View Full Code Here
695
696
697
698
699
700
701
702
703
704
705
                  throw new BrokerException(
                  "Transaction XID mismatch "+xid+", expected "+ts.getXid()+" for transaction "+id);
              }
          }

          handler.doCommit(id, xid, xaFlags, ts, conlist, false,con, null);
     }

    /**
     * prepare a transaction.
     * @param id  The TransactionUID to prepare
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.