Package javax.transaction

Examples of javax.transaction.TransactionManager.resume()

449
450
451
452
453
454
455
456
457
458
459
      mgr.commit();

      assertEquals(1, cache.getTransactionTable().getNumGlobalTransactions());
      assertEquals(1, cache.getTransactionTable().getNumLocalTransactions());

      mgr.resume(tx);

      boolean fail = false;
      try
      {
         mgr.commit();
View Full Code Here
523
524
525
526
527
528
529
530
531
532
533
      // assert we can see this outside the existing tx
      assertEquals(pojo2, cache.get("/one/two", "key2"));
      System.out.println("Current TX " + mgr.getTransaction());
      // resume the suspended one
      mgr.resume(tx);
      System.out.println("Current TX " + mgr.getTransaction());
      // assert we can't see the change from tx2 as we already touched the node
      assertEquals(null, cache.get("/one/two", "key2"));
      mgr.commit();
      destroyCache(cache);
View Full Code Here
567
568
569
570
571
572
573
574
575
576
577
      // assert we can see this outsode the existing tx
      assertEquals(2, cache.getNode("/one/two").getKeys().size());

      // resume the suspended one
      mgr.resume(tx);
      // assert we can't see thge change from tx2 as we already touched the node
      assertEquals(1, cache.getNode("/one/two").getKeys().size());
      mgr.commit();
      destroyCache(cache);
View Full Code Here
614
615
616
617
618
619
620
621
622
623
624
      keys = cache.getNode("/one/two").getKeys();
      System.out.println("keys after TX #3 committed: " + keys);
      assertEquals(2, keys.size());

      // resume the suspended one
      mgr.resume(tx);
      // assert we can't see the change from tx2 as we already touched the node
      keys = cache.getNode("/one/two").getKeys();
      System.out.println("keys after TX #2 resumed (in private workspace of TX #2): " + keys);
      assertEquals(2, keys.size());// we will see key1 and key2, but *not* key3

 
View Full Code Here
671
672
673
674
675
676
677
678
679
680
681
      mgr.begin();
      assertNull(cache.get(fqn, key));
      mgr.commit();

      mgr.resume(tx);
      assertEquals(value, cache.get(fqn, key));
      mgr.commit();

      assertEquals(value, cache.get(fqn, key));
View Full Code Here
555
556
557
558
559
560
561
562
563
564
565
         // expected
         //cache.getTransactionManager().commit();
         tm.commit();
      }

      tm.resume(t);
      tx.rollback();

      assertNotNull(cache.getNode("/a/b/c"));
      assertEquals(0, cache.getNumberOfLocksHeld());
   }
View Full Code Here
140
141
142
143
144
145
146
147
148
149
150
      mgr.commit();

      assertEquals(1, cache.getTransactionTable().getNumGlobalTransactions());
      assertEquals(1, cache.getTransactionTable().getNumLocalTransactions());

      mgr.resume(tx);

      // one-phase-commits wont throw an exception on failure.
      try
      {
         mgr.commit();
View Full Code Here
347
348
349
350
351
352
353
354
355
356
357
      TestingUtil.sleepThread((long) 1000);

      assertEquals(1, cache.getTransactionTable().getNumGlobalTransactions());
      assertEquals(1, cache.getTransactionTable().getNumLocalTransactions());

      mgr.resume(tx);

      try
      {
         mgr.commit();
         assert false : "Expecting an exception";
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
      // should succeed...
      mgr1.commit();

      try
      {
         mgr2.resume(tx2);
         mgr2.commit();
         assertTrue("Should have failed", false);
      }
      catch (RollbackException rbe)
      {
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
      assertEquals(value + value, cache.get(abcd, key));
      assertEquals(value, cache.get(abce, key));
      assertEquals(value, cache.get(abcf, key));
      assertEquals(value, cache.get(abcg, key));

      tm.resume(tx);
      tm.commit();

      assertEquals(value, cache.get(abxy, key));

      NodeSPI<Object, Object> n = cache.getRoot();
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.