Examples of registerSynchronization()

Examples of com.sun.enterprise.transaction.spi.TransactionInternal.registerSynchronization()

426
427
428
429
430
431
432
433
434
435
436
                monitor.transactionDeactivatedEvent();
            }
        }

        tx.setJTSTx(jtsTx);
        jtsTx.registerSynchronization(new JTSSynchronization(jtsTx, this));
    }

    /**
     * get the resources being used in the calling component's invocation context
     * @param instance Calling component instance
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

86
87
88
89
90
91
92
93
94
95
96
      cacheB.put("/1/A/I", "2", "B");
      cacheB.put("/EXISTS", "KEY", "B");

      Object monitor = new Object();
      HangSync sync = new HangSync(monitor);
      tx.registerSynchronization(sync);

      Thread t = new Thread()
      {
         public void run()
         {
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

67
68
69
70
71
72
73
74
75
76
77
         if ("testBadUserTx".equals(mi.getMethod().getName()))
         {
            Transaction tx = tm.getTransaction();
            if (tx != null)
            {
               tx.registerSynchronization(new BadTxSynchronization());
               log.debug("Registered BdTxSynchronization");
            }
            else
            {
               log.error("No transaction registered!!");
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

494
495
496
497
498
499
500
501
502
503
504
               assertNotNull(tm);

               tm.setTransactionTimeout(2);
               tm.begin();
               Transaction tx = tm.getTransaction();
               tx.registerSynchronization(this);

               cl = cm.getManagedConnection(subject, cri);
               cl.enlist();

               latch.await(20, TimeUnit.SECONDS);
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

391
392
393
394
395
396
397
398
399
400
401
      Transaction tx = timerService.getTransaction();
      if (tx != null)
      {
         try
         {
            tx.registerSynchronization(this);
         }
         catch (Exception e)
         {
            log.error("Cannot register txtimer with Tx: " + this);
         }
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

288
289
290
291
292
293
294
295
296
297
298
         public void afterCompletion(int status)
         {
            log.info (tid() + " afterCompletion(" + TxUtils.getStatusAsString(status) + ") called");
         }        
      };
      tx.registerSynchronization(sync);
   }
  
   public void xxWaitForTx() throws Exception
   {
      log.info(tid() + " XX_WAIT_FOR (" + id + ")");
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

91
92
93
94
95
96
97
98
99
100
101
      TransactionManagerImpl tm = TransactionManagerImpl.getLocal();

      Transaction xa = tm.getTransaction();

      if (xa != null && sync != null) {
        xa.registerSynchronization(new SynchronizationAdapter(sync));
       
        sync.afterBegin();
      }
    } catch (RuntimeException e) {
      throw e;
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

243
244
245
246
247
248
249
250
251
252
253
    void registerSynchronization(Synchronization sync) throws RollbackException, SystemException {
        Transaction transaction = transactionManager.getTransaction();
        int status = transaction == null ? Status.STATUS_NO_TRANSACTION : transaction.getStatus();

        if (transaction != null && status == Status.STATUS_ACTIVE || status == Status.STATUS_MARKED_ROLLBACK) {
            transaction.registerSynchronization(sync);
        } else {
            sync.beforeCompletion();
            sync.afterCompletion(Status.STATUS_COMMITTED);
        }
    }
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

739
740
741
742
743
744
745
746
747
748
749
                trans = tm.getTransaction();
            } else if (trans == null)
                return false;

            // synch broker and trans
            trans.registerSynchronization(broker);

            // we don't need to synchronize on brokers or guard against multiple
            // threads using the same trans since one JTA transaction can never
            // be active on multiple concurrent threads.
            Object txKey = mr.getTransactionKey();
View Full Code Here

Examples of javax.transaction.Transaction.registerSynchronization()

750
751
752
753
754
755
756
757
758
759
760
            Collection<Broker> brokers = _transactional.get(txKey);
           
            if (brokers == null) {
                brokers = new ArrayList<Broker>(2);
                _transactional.put(txKey, brokers);
                trans.registerSynchronization(new RemoveTransactionSync(txKey));
            }
            brokers.add(broker);
           
            return true;
        } catch (OpenJPAException ke) {
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.