Examples of net.jini.core.transaction.Transaction.commit()

Class net.jini.core.transaction.Transaction

Examples of net.jini.core.transaction.Transaction.commit()

net.jini.core.transaction.Transaction.commit()
Commit the transaction. Commit asks the transaction manager to execute the voting process with the participants. Returns if the transaction successfully reaches either the NOTCHANGED or the COMMITTED state, without waiting for the transaction manager to notify all participants of the decision. If the transaction must be aborted (because one or more participants are unable to prepare), CannotCommitException is thrown without waiting for the transaction manager to notify all participants of the decision. @throws UnknownTransactionException if the transaction is unknown to the manager. This may be because the transaction ID was incorrect, or because the transaction has proceeded to cleanup due to an earlier commit or abort, and has been forgotten. @throws CannotCommitException if the transaction reaches the ABORTED state, or is known to have previously reached that state due to an earlier commit or abort. @throws RemoteException if a communication error occurs.

            }
            throw new RuntimeCamelException(e);
        } finally {
            if (tnx != null) {
                try {
                    tnx.commit();
                } catch (UnknownTransactionException e1) {
                    throw new RuntimeCamelException(e1);
                } catch (RemoteException e1) {
                    throw new RuntimeCamelException(e1);
                } catch (CannotCommitException e1) {

View Full Code Here

                    obj = ois.readObject();
                }
                exchange.getOut().setBody(obj);
            }
            if (tnx != null) {
                tnx.commit();
            }
        }
    }


    @Override

View Full Code Here

                obj = ois.readObject();
            }
            exchange.getOut().setBody(obj);
        }
        if (tnx != null) {
            tnx.commit();
        }
        
    }


    @Override

View Full Code Here

            }
            throw new RuntimeCamelException(e);
        } finally {
            if (tnx != null) {
                try {
                    tnx.commit();
                } catch (UnknownTransactionException e1) {
                    throw new RuntimeCamelException(e1);
                } catch (RemoteException e1) {
                    throw new RuntimeCamelException(e1);
                } catch (CannotCommitException e1) {

View Full Code Here

            }
            throw new RuntimeCamelException(e);
        } finally {
            if (tnx != null) {
                try {
                    tnx.commit();
                } catch (UnknownTransactionException e1) {
                    throw new RuntimeCamelException(e1);
                } catch (RemoteException e1) {
                    throw new RuntimeCamelException(e1);
                } catch (CannotCommitException e1) {

View Full Code Here

                obj = ois.readObject();
            }
            exchange.getOut().setBody(obj);
        }
        if (tnx != null) {
            tnx.commit();
        }
        
    }


    @Override

View Full Code Here

            logger.log(Level.INFO, "...awake");
        } catch (InterruptedException e) {}


        // Check abort/commit cause RemoteException
        try {
            txn.commit();
      throw new TestException("Expected exception was NOT thrown.");
        } catch (RemoteException e) {
            pass("step-4: RemoteException was thrown, as expected.");
        }
    }

View Full Code Here

  Thread.sleep(15000);
  takeThread.confirmCallInProgress();


  logger.log(Level.INFO, "calling " + resolve);
  if (commit)
      txn2.commit(60000);
  else 
      txn2.abort(60000);
  logger.log(Level.INFO, resolve + " returned");


  if (takeThread.waitOnTakeReturn(30000)) {

View Full Code Here

        }


        if (null == space.take(entry, txn, 0)) {
            throw new TestException( "Could not perform take");
        }
        txn.commit(60000);


        if (null != space.read(entry, null, 0)) {
            throw new TestException(
                    "Confirming read returned non-null value");
        }

View Full Code Here

            }
            throw new RuntimeCamelException(e);
        } finally {
            if (tnx != null) {
                try {
                    tnx.commit();
                } catch (UnknownTransactionException e1) {
                    throw new RuntimeCamelException(e1);
                } catch (RemoteException e1) {
                    throw new RuntimeCamelException(e1);
                } catch (CannotCommitException e1) {

View Full Code Here

0 1 2 3 4

TOP

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.