Package javax.transaction

Examples of javax.transaction.TransactionManager.resume()

421
422
423
424
425
426
427
428
429
430
431
         else
         {
            // If there is already a transaction we ignore the XAResource (by spec 12.5.9)
            try
            {
               tm.resume(suspended);
            }
            finally
            {
               suspended = null;
               if (trace)
View Full Code Here
457
458
459
460
461
462
463
464
465
466
467
            // Suspend any bad transaction - there is bug somewhere, but we will try to tidy things up
            if (currentTx != null && currentTx.equals(transaction) == false)
            {
               log.warn("Current transaction " + currentTx + " is not the expected transaction.");
               tm.suspend();
               tm.resume(transaction);
            }
            else
            {
               // We have the correct transaction
               currentTx = null;
View Full Code Here
486
487
488
489
490
491
492
493
494
495
496
         if (suspended != null)
         {
            try
            {
               tm = TxUtil.getTransactionManager(); //getContainer(mi).getTransactionManager();
               tm.resume(suspended);
            }
            finally
            {
               suspended = null;
            }
View Full Code Here
504
505
506
507
508
509
510
511
512
513
514
         // Resume any suspended transaction
         if (currentTx != null)
         {
            try
            {
               tm.resume(currentTx);
            }
            catch (Throwable t)
            {
               log.warn("MessageEndpoint " + getProxyString(proxy) + " failed to resume old transaction " + currentTx);
              
View Full Code Here
168
169
170
171
172
173
174
175
176
177
178
        }
      }
      finally {
        if ( surroundingTransaction != null ) {
          try {
            transactionManager.resume( surroundingTransaction );
            if ( log.isDebugEnabled() ) {
              log.debug( "surrounding JTA transaction resumed [" + surroundingTransaction + "]" );
            }
          }
          catch( Throwable t ) {
View Full Code Here
323
324
325
326
327
328
329
330
331
332
333
      }
      finally
      {
         if (toResume != null)
         {
            tm.resume(toResume);
         }
      }
     
      if (ok)
      {        
View Full Code Here
359
360
361
362
363
364
365
366
367
368
369
      }
      finally
      {
         if (toResume != null)
         {
            tm.resume(toResume);
         }
      }

      if (ok)
      {
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
        hadProblems = true;
        throw e;
      }
      finally {
        try {
          transactionManager.resume( surroundingTransaction );
          LOG.debugf( "Surrounding JTA transaction resumed [%s]", surroundingTransaction );
        }
        catch( Throwable t ) {
          // if the actually work had an error use that, otherwise error based on t
          if ( !hadProblems ) {
View Full Code Here
1516
1517
1518
1519
1520
1521
1522
1523
1524
1525
1526
      executeStatement(mgr, ds, "DROP TABLE JBM_DUAL");

      if (txOld != null)
      {
         mgr.resume(txOld);
      }

      log.debug("done with dropping tables");
   }
View Full Code Here
1554
1555
1556
1557
1558
1559
1560
1561
1562
1563
1564
      executeStatement(mgr, ds, "DELETE FROM JBM_ID_CACHE");

      if (txOld != null)
      {
         mgr.resume(txOld);
      }

      log.debug("done with the deleting data");
   }
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.