Examples of com.sun.sgs.service.Transaction.join()

com.sun.sgs.service.Transaction.join()
Tells the Transaction that the given TransactionParticipant is participating in the transaction. A TransactionParticipant is allowed to join a Transaction more than once, but will only be registered as a single participant.
If the transaction has been aborted, then the exception thrown will have as its cause the value provided in the first call to {@link #abort abort}, if any. If the cause implements {@link ExceptionRetryStatus}, then the exception thrown will, too, and its {@link ExceptionRetryStatus#shouldRetry shouldRetry} method will return thevalue returned by calling that method on the cause. If no cause was supplied, then the exception will either not implement {@code ExceptionRetryStatus} or its {@code shouldRetry} method will return{@code false}. @param participant the TransactionParticipant joiningthe transaction @throws TransactionNotActiveException if the transaction has beenaborted @throws IllegalStateException if {@link TransactionParticipant#prepare prepare} has been called on anytransaction participant and the transaction has not been aborted, or if called from a thread that is not the thread that created this transaction @throws UnsupportedOperationException if participant doesnot implement {@link NonDurableTransactionParticipant} and theimplementation cannot support an additional durable transaction participant

            if (logger.isLoggable(Level.FINER)) {
                logger.log(Level.FINER, "join txn:{0}", txn);
            }
            context = contextFactory.createContext(txn);
            currentContext.set(context);
            txn.join(contextFactory.getParticipant());
        } else if (!txn.equals(context.getTransaction())) {
            clearContext();
            throw new IllegalStateException(
                "Wrong transaction: Expected " + context.getTransaction() +
                ", found " + txn);

View Full Code Here

      // buffering
      handler.publish(record);
        } else {
      Queue<LogRecord> records = bufferedRecords.get(txn);
      if (records == null) {
    txn.join(this);
    records = new ArrayDeque<LogRecord>();
    // this code path is guaranteed to be unique by way of
    // the transaction's uniqueness, so we don't need to
    // worry about a race condition with putting the queue
    // into the map

View Full Code Here

      // buffering
      handler.publish(record);
        } else {
      Queue<LogRecord> records = bufferedRecords.get(txn);
      if (records == null) {
    txn.join(this);
    records = new ArrayDeque<LogRecord>();
    // this code path is guaranteed to be unique by way of
    // the transaction's uniqueness, so we don't need to
    // worry about a race condition with putting the queue
    // into the map

View Full Code Here

                            }
                        }
                    }
                    Participant participant = new Participant();
                    Transaction txn = txnProxy.getCurrentTransaction();
                    txn.join(participant);
                    txn.abort(new TestAbortedTransactionException("abort"));
                    assertTrue("Action should throw", participant.ok);
            }}, taskOwner);


        } catch (TestAbortedTransactionException e) {

View Full Code Here

            txnScheduler.runTask(new InitialTestRunnable() {
                public void run() throws Exception {
                    super.run();
                    action.setUp();
                    Transaction txn = txnProxy.getCurrentTransaction();
                    txn.join(participant);
                }}, taskOwner);
        } catch (TransactionNotActiveException e) {
            System.err.println(e);
        }
        assertTrue("Action should throw", participant.ok);

View Full Code Here

            txnScheduler.runTask(new InitialTestRunnable() {
                public void run() throws Exception {
                    super.run();
                    action.setUp();
                    Transaction txn = txnProxy.getCurrentTransaction();
                    txn.join(participant);
            }}, taskOwner);
        }  catch (TransactionNotActiveException e) {
            System.err.println(e);
        }
  assertTrue("Action should throw", participant.ok);

View Full Code Here

            if (logger.isLoggable(Level.FINER)) {
                logger.log(Level.FINER, "join txn:{0}", txn);
            }
            context = contextFactory.createContext(txn);
            currentContext.set(context);
            txn.join(contextFactory.getParticipant());
        } else if (!txn.equals(context.getTransaction())) {
            clearContext();
            throw new IllegalStateException(
                "Wrong transaction: Expected " + context.getTransaction() +
                ", found " + txn);

View Full Code Here

                            }
                        }
                    }
                    Participant participant = new Participant();
                    Transaction txn = txnProxy.getCurrentTransaction();
                    txn.join(participant);
                    txn.abort(new TestAbortedTransactionException("abort"));
                    assertTrue("Action should throw", participant.ok);
            }}, taskOwner);


        } catch (TestAbortedTransactionException e) {

View Full Code Here

            txnScheduler.runTask(new InitialTestRunnable() {
                public void run() throws Exception {
                    super.run();
                    action.setUp();
                    Transaction txn = txnProxy.getCurrentTransaction();
                    txn.join(participant);
                }}, taskOwner);
        } catch (TransactionNotActiveException e) {
            System.err.println(e);
        }
        assertTrue("Action should throw", participant.ok);

View Full Code Here

            txnScheduler.runTask(new InitialTestRunnable() {
                public void run() throws Exception {
                    super.run();
                    action.setUp();
                    Transaction txn = txnProxy.getCurrentTransaction();
                    txn.join(participant);
            }}, taskOwner);
        }  catch (TransactionNotActiveException e) {
            System.err.println(e);
        }
  assertTrue("Action should throw", participant.ok);

View Full Code Here

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.