Examples of TransactionImple


Examples of com.arjuna.ats.internal.jta.transaction.arjunacore.TransactionImple

     * @throws NotSupportedException
     */
    Transaction beginUserTransaction(final UserTransactionID userTransactionID) throws SystemException, NotSupportedException {
        this.getUserTransaction().begin();
        // get the tx that just got created and associated with the transaction manager
        final TransactionImple newlyAssociatedTx = TransactionImple.getTransaction();
        final Uid uid = newlyAssociatedTx.get_uid();
        this.userTransactions.put(userTransactionID, uid);
        return newlyAssociatedTx;
    }
View Full Code Here

Examples of com.arjuna.ats.internal.jta.transaction.arjunacore.TransactionImple

     * @throws NotSupportedException
     */
    Transaction beginUserTransaction(final UserTransactionID userTransactionID) throws SystemException, NotSupportedException {
        this.getUserTransaction().begin();
        // get the tx that just got created and associated with the transaction manager
        final TransactionImple newlyAssociatedTx = TransactionImple.getTransaction();
        final Uid uid = newlyAssociatedTx.get_uid();
        this.userTransactions.put(userTransactionID, uid);
        return newlyAssociatedTx;
    }
View Full Code Here

Examples of com.arjuna.ats.internal.jta.transaction.arjunacore.TransactionImple

/* 121 */     return TRANSACTION_MANAGER;
/*     */   }
/*     */
/*     */   public boolean containsValue(TransactionLocal transactionLocal, Transaction transaction)
/*     */   {
/* 145 */     TransactionImple transactionImple = (TransactionImple)transaction;
/* 146 */     if (transactionImple.isAlive()) {
/* 147 */       return transactionImple.getTxLocalResource(transactionLocal) != null;
/*     */     }
/* 149 */     return false;
/*     */   }
View Full Code Here

Examples of com.arjuna.ats.internal.jta.transaction.arjunacore.TransactionImple

/* 149 */     return false;
/*     */   }
/*     */
/*     */   public Object getValue(TransactionLocal transactionLocal, Transaction transaction)
/*     */   {
/* 161 */     TransactionImple transactionImple = (TransactionImple)transaction;
/* 162 */     if (transactionImple.isAlive()) {
/* 163 */       return transactionImple.getTxLocalResource(transactionLocal);
/*     */     }
/* 165 */     return null;
/*     */   }
View Full Code Here

Examples of com.arjuna.ats.internal.jta.transaction.arjunacore.TransactionImple

/* 165 */     return null;
/*     */   }
/*     */
/*     */   public void storeValue(TransactionLocal transactionLocal, Transaction transaction, Object value)
/*     */   {
/* 178 */     TransactionImple transactionImple = (TransactionImple)transaction;
/* 179 */     if (transactionImple.isAlive())
/* 180 */       transactionImple.putTxLocalResource(transactionLocal, value);
/*     */     else
/* 182 */       throw new IllegalStateException("Can't store value in a TransactionLocal after the Transaction has ended");
/*     */   }
View Full Code Here

Examples of com.arjuna.ats.internal.jta.transaction.arjunacore.subordinate.TransactionImple

 
  public void commit (Xid xid, boolean onePhase) throws XAException
  {
    try
    {
      TransactionImple tx = TxImporter.getImportedTransaction(xid);
     
      if (tx == null)
        throw new XAException(XAException.XAER_INVAL);
     
      if (onePhase)
        tx.doOnePhaseCommit();
      else
        tx.doCommit();
     
      TxImporter.removeImportedTransaction(xid);
    }
    catch (XAException ex)
    {
View Full Code Here

Examples of com.arjuna.ats.internal.jta.transaction.arjunacore.subordinate.TransactionImple

 
  public void forget (Xid xid) throws XAException
  {
    try
    {
      TransactionImple tx = TxImporter.getImportedTransaction(xid);
     
      if (tx == null)
        throw new XAException(XAException.XAER_INVAL);
     
      tx.doForget();
    }
    catch (Exception ex)
    {
      throw new XAException(XAException.XAER_RMERR);
    }
View Full Code Here

Examples of com.arjuna.ats.internal.jta.transaction.arjunacore.subordinate.TransactionImple

 
  public int prepare (Xid xid) throws XAException
  {
    try
    {
      TransactionImple tx = TxImporter.getImportedTransaction(xid);
     
      if (tx == null)
        throw new XAException(XAException.XAER_INVAL);
     
      switch (tx.doPrepare())
      {
      case TwoPhaseOutcome.PREPARE_READONLY:
        TxImporter.removeImportedTransaction(xid);
       
        return XAResource.XA_RDONLY;       
View Full Code Here

Examples of com.arjuna.ats.internal.jta.transaction.arjunacore.subordinate.TransactionImple

            finished = true;
          }
         
          if (uid.notEquals(Uid.nullUid()))
          {
            TransactionImple tx = TxImporter.recoverTransaction(uid);
           
            if (tx != null)
              values.push(tx);
          }
          else
            finished = true;
         
        } while (!finished);
       
        if (values.size() > 0)
        {
          int index = 0;

          indoubt = new Xid[values.size()];
               
          while (!values.empty())
          {
            com.arjuna.ats.internal.jta.transaction.arjunacore.subordinate.jca.TransactionImple tx = (com.arjuna.ats.internal.jta.transaction.arjunacore.subordinate.jca.TransactionImple) values.pop();
           
            indoubt[index] = tx.baseXid();
            index++;
          }
        }
      }
    }
View Full Code Here

Examples of com.arjuna.ats.internal.jta.transaction.arjunacore.subordinate.TransactionImple

 
  public void rollback (Xid xid) throws XAException
  {
    try
    {
      TransactionImple tx = TxImporter.getImportedTransaction(xid);
     
      if (tx == null)
        throw new XAException(XAException.XAER_INVAL);
     
      tx.doRollback();
     
      TxImporter.removeImportedTransaction(xid);
    }
    catch (XAException ex)
    {
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.