Package javax.transaction

Examples of javax.transaction.TransactionManager.rollback()

134
135
136
137
138
139
140
141
142
143
144
      assertTrue(!caches.get(2).exists(oldBackupFqn));
      assertTrue(!caches.get(0).exists(newBackupFqn));
      assertTrue(!caches.get(1).exists(newBackupFqn));
      assertTrue(!caches.get(2).exists(newBackupFqn));

      txman.rollback();

      dumpCacheContents(caches);

      assertTrue(caches.get(0).exists(fqn));
      assertTrue(!caches.get(1).exists(fqn));
View Full Code Here
104
105
106
107
108
109
110
111
112
113
114
                  this.e = e;
               }

               try
               {
                  if (tm.getTransaction() != null) tm.rollback();
               }
               catch (Exception e2)
               {
                  log.error("Rollback failed!", e2);
               }
View Full Code Here
63
64
65
66
67
68
69
70
71
72
73
               TransactionManager tm = c.getTransactionManager();
               if (tm != null)
               {
                  try
                  {
                     if (tm.getTransaction() != null) tm.rollback();
                  }
                  catch (Exception e)
                  {
                     // error rolling back gtx2EntryMap
                     e.printStackTrace();
View Full Code Here
417
418
419
420
421
422
423
424
425
426
427
         System.out.println("Transaction was rolled back, this is correct");
      }
      finally
      {
         tm.resume(tx2);
         tm.rollback();
      }

      // Sleep, as the commit call to cache2 is async
      TestingUtil.sleepThread(1000);
View Full Code Here
652
653
654
655
656
657
658
659
660
661
662
            finally
            {
               try
               {
                  if (tm != null)
                     tm.rollback();
               }
               catch (Exception e)
               {
                  // do nothing
               }
View Full Code Here
1053
1054
1055
1056
1057
1058
1059
1060
1061
1062
1063
               c2.put("/a/b/c", "age", 39);
               lock.release();

               TestingUtil.sleepThread(100);
               lock.acquire();
               tm.rollback();
               lock.release();
            }
            catch (Throwable ex)
            {
               ex.printStackTrace();
View Full Code Here
652
653
654
655
656
657
658
659
660
661
662
            finally
            {
               try
               {
                  if (tm != null)
                     tm.rollback();
               }
               catch (Exception e)
               {
                  // do nothing
               }
View Full Code Here
192
193
194
195
196
197
198
199
200
201
202
         TransactionManager txManager = txManager();
         txManager.resume(localTx.getTransaction());
         if (commit) {
            txManager.commit();
         } else {
            txManager.rollback();
         }
      }

      private void replayModificationsInTransaction(PrepareCommand command, boolean onePhaseCommit) throws Throwable {
         TransactionManager tm = txManager();
View Full Code Here
216
217
218
219
220
221
222
223
224
225
226
                  if( replaySuccessful ) {
                     log.tracef("Committing remotely originated tx %s as it is 1PC", command.getGlobalTransaction());
                     tm.commit();
                  } else {
                     log.tracef("Rolling back remotely originated tx %s", command.getGlobalTransaction());
                     tm.rollback();
                  }
               } else { // Wait for a remote commit/rollback.
                  remote2localTx.put(command.getGlobalTransaction(), localTx.getGlobalTransaction());
                  tm.suspend();
               }
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
   {
      TransactionManager tm = c.getTransactionManager();
      try
      {
         if (tm != null && tm.getTransaction() != null)
            tm.rollback();
      }
      catch (Exception e)
      {
      }
      c.stop();
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.