Package javax.transaction

Examples of javax.transaction.TransactionManager.resume()

338
339
340
341
342
343
344
345
346
347
348
      catch (RollbackException roll)
      {
         assertTrue("Ought to have succeeded!", false);
      }

      mgr2.resume(tx2);
      try
      {
         mgr2.commit();
         assertTrue("Ought to have succeeded!", true);
      }
View Full Code Here
120
121
122
123
124
125
126
127
128
129
130
      cache1.getNotifier().addCacheListener(lis);
      lis.put("/a/b/c", "age", 38);

      tm.suspend();
      assertNull("age on cache2 must be null as the TX has not yet been committed", cache2.get("/a/b/c", "age"));
      tm.resume(tx);
      tm.commit();

      // value on cache2 must be 38
      age = (Integer) cache2.get("/a/b/c", "age");
      assertNotNull("\"age\" obtained from cache2 must be non-null ", age);
View Full Code Here
170
171
172
173
174
175
176
177
178
179
180
      map.put("age", 38);
      map.put("name", "Ben");
      lis.put("/a/b/c", map);
      tm.suspend();
      assertNull("age on cache2 must be null as the TX has not yet been committed", cache2.get("/a/b/c", "age"));
      tm.resume(tx);
      tm.commit();

      // value on cache2 must be 38
      age = (Integer) cache2.get("/a/b/c", "age");
      assertNotNull("\"age\" obtained from cache2 must be non-null ", age);
View Full Code Here
700
701
702
703
704
705
706
707
708
709
710
      mgr.begin();
      assertEquals(value, cache.get(fqn, key));
      mgr.commit();

      mgr.resume(tx);
      assertNull(cache.getNode(fqn));
      mgr.commit();

      assertNull(cache.getNode(fqn));
   }
View Full Code Here
728
729
730
731
732
733
734
735
736
737
738
      mgr.begin();
      assertEquals(value, cache.get(fqn, key));
      mgr.commit();

      mgr.resume(tx);
      assertNull(cache.getNode(fqn));
      mgr.commit();

      assertNull(cache.getNode(fqn));
   }
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
      {
         public void run()
         {
            try
            {
               tm.resume(tx);
               tm.commit();
            }
            catch (Exception e)
            {
            }
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
         // start a new tx
         mgr.begin();
         assertEquals(value, cache.get(fqn, key));
         mgr.commit();

         mgr.resume(tx);
         assertEquals(value, cache.get(fqn, key));
         mgr.commit();
      }
      finally
      {
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
      // lets see what we've got halfway within a tx
      assertNull(cache.get(fqn, key));
      assertNull(loader.get(fqn));

      mgr.resume(tx);
      mgr.commit();

      // and after committing...
      assertEquals(value, cache.get(fqn, key));
      assertEquals(value, loader.get(fqn).get(key));
View Full Code Here
174
175
176
177
178
179
180
181
182
183
184
      cache1.put("/a/b/c", "age", 38);
      tx = mgr.suspend();
      assertNull("age on cache2 must be null as the TX has not yet been committed", cache2.get("/a/b/c", "age"));
      log.debug("cache1: locks held before commit: " + CachePrinter.printCacheLockingInfo(cache1));
      log.debug("cache2: locks held before commit: " + CachePrinter.printCacheLockingInfo(cache2));
      mgr.resume(tx);
      mgr.commit();
      log.debug("cache1: locks held after commit: " + CachePrinter.printCacheLockingInfo(cache1));
      log.debug("cache2: locks held after commit: " + CachePrinter.printCacheLockingInfo(cache2));

      // value on cache2 must be 38
View Full Code Here
403
404
405
406
407
408
409
410
411
412
413
      tm.begin();
      cache2.getRoot().put("x", "y");
      Transaction tx2 = cache2.getTransactionManager().suspend();

      System.out.println("cache2 (before commit):\n" + CachePrinter.printCacheLockingInfo(cache2));
      tm.resume(tx);

      try
      {
         tm.commit();
         fail("commit should throw a RollbackException, we should not get here");
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.