Package javax.transaction

Examples of javax.transaction.TransactionManager.rollback()

150
151
152
153
154
155
156
157
158
159
160
        catch( Throwable ignore ) {
          log.trace( "unable to release connection on exception [" + ignore + "]" );
        }
        if ( transacted ) {
          try {
            transactionManager.rollback();
          }
          catch( Throwable ignore ) {
            log.trace( "unable to rollback new transaction on exception [" + ignore + "]" );
          }
        }
View Full Code Here
72
73
74
75
76
77
78
79
80
81
82
         case Status.STATUS_MARKED_ROLLBACK:
         case Status.STATUS_PREPARING:
         case Status.STATUS_ROLLING_BACK:
            try
            {
               tm.rollback();
            }
            catch (Exception ex)
            {
               log.error("Failed to rollback", ex);
            }
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
        catch( Throwable ignore ) {
          log.trace( "unable to release connection on exception [" + ignore + "]" );
        }
        if ( transacted ) {
          try {
            transactionManager.rollback();
          }
          catch( Throwable ignore ) {
            log.trace( "unable to rollback new transaction on exception [" + ignore + "]" );
          }
        }
View Full Code Here
575
576
577
578
579
580
581
582
583
584
585
         tx.delistResource(res, XAResource.TMSUCCESS);

         tx.delistResource(consumerSess.getXAResource(), XAResource.TMSUCCESS);

         mgr.rollback();

         // Must close consumer first

         consumer.close();
View Full Code Here
527
528
529
530
531
532
533
534
535
536
537
         tx.delistResource(res, XAResource.TMSUCCESS);

         tx.delistResource(consumerSess.getXAResource(), XAResource.TMSUCCESS);

         mgr.rollback();

         mgr.begin();

         tx = mgr.getTransaction();
View Full Code Here
551
552
553
554
555
556
557
558
559
560
561
         tx.delistResource(res, XAResource.TMSUCCESS);

         tx.delistResource(consumerSess.getXAResource(), XAResource.TMSUCCESS);

         mgr.rollback();

         mgr.begin();

         tx = mgr.getTransaction();
View Full Code Here
201
202
203
204
205
206
207
208
209
210
211
      assertEquals("value2", cache1.get(fqn, "key2"));

      txm.begin();
      cache2.put(fqn, "key", "value");
      assertEquals("value", cache2.get(fqn, "key"));
      txm.rollback();

      assertEquals("value2", cache1.get(fqn, "key2"));
      n = cache2.getNode(fqn);
      assertHasBeenInvalidated(n, "Should have been invalidated");
   }
View Full Code Here
623
624
625
626
627
628
629
630
631
632
633
      txm.begin();
      cache2.put(fqn, "key", "value");
      assertEquals("value2", cache1.get(fqn, "key2"));
      assertEquals("value", cache2.get(fqn, "key"));
      txm.rollback();

      assertEquals("value2", cache1.get(fqn, "key2"));
      n2 = cache2.getNode(fqn);
      assertHasBeenInvalidated(n2, "Should have been invalidated");
      assertHasBeenInvalidated(cache2.peek(fqn, false, false), "Should have been invalidated");
View Full Code Here
676
677
678
679
680
681
682
683
684
685
686
      assertEquals("value", caches.get(0).get(fqn, "key"));

      mgr.begin();
      caches.get(0).put(fqn, "key2", "value2");
      assertEquals("value2", caches.get(0).get(fqn, "key2"));
      mgr.rollback();
      assertEquals("value", caches.get(1).get(fqn, "key"));
      assertEquals("value", caches.get(0).get(fqn, "key"));
      assertNull("Should be null", caches.get(0).get(fqn, "key2"));
      assertNull("Should be null", caches.get(1).get(fqn, "key2"));
   }
View Full Code Here
705
706
707
708
709
710
711
712
713
714
715
      mgr.begin();
      caches.get(0).put(fqn, "key2", "value2");
      assertEquals("value2", caches.get(0).get(fqn, "key2"));
      assertNull("Should be null", caches.get(1).get(fqn, "key2"));
      mgr.rollback();
      assertEquals("value", caches.get(1).get(fqn, "key"));
      assertEquals("value", caches.get(0).get(fqn, "key"));
      assertNull("Should be null", caches.get(0).get(fqn, "key2"));
      assertNull("Should be null", caches.get(1).get(fqn, "key2"));
   }
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.