Package javax.transaction

Examples of javax.transaction.TransactionManager.rollback()

175
176
177
178
179
180
181
182
183
184
185
      assertEquals(0, c.getTransactionTable().getNumGlobalTransactions());
      assertEquals(0, c.getTransactionTable().getNumLocalTransactions());

      mgr.begin();
      c.put("/one/two", "key1", "value");
      mgr.rollback();
      assertNull(mgr.getTransaction());
      assertEquals(0, c.getTransactionTable().getNumGlobalTransactions());
      assertEquals(0, c.getTransactionTable().getNumLocalTransactions());

      //make sure all calls were done in right order
View Full Code Here
152
153
154
155
156
157
158
159
160
161
162
      SamplePojo pojo = new SamplePojo(21, "test");

      cache.put("/one/two", "key1", pojo);

      mgr.rollback();

      assertNull(mgr.getTransaction());
      assertEquals(0, cache.getTransactionTable().getNumGlobalTransactions());
      assertEquals(0, cache.getTransactionTable().getNumLocalTransactions());
View Full Code Here
1161
1162
1163
1164
1165
1166
1167
1168
1169
1170
1171
      mgr.begin();

      cache.put("/one/two/three", "key1", "val1");
      cache.put("/one/two/three/four", "key2", "val2");
      log.debug("NODE1 " + cache.getNode("/one/two/three").getData());
      mgr.rollback();
      log.debug("NODE2 " + cache.getNode("/one/two/three"));
      assertEquals(null, cache.get("/one/two/three", "key1"));
      assertEquals(null, cache.get("/one/two/three/four", "key2"));
      addDelay();
      assertNull("Loader should not have node /one/two/three", loader.get(Fqn.fromString("/one/two/three")));
View Full Code Here
537
538
539
540
541
542
543
544
545
546
547
   {

      CacheSPI<Object, Object> cache = createCacheWithListener();

      TransactionManager mgr = cache.getConfiguration().getRuntimeConfig().getTransactionManager();
      if (mgr.getTransaction() != null) mgr.rollback();
      assertNull(mgr.getTransaction());

      // first put in a value
      mgr.begin();
View Full Code Here
582
583
584
585
586
587
588
589
590
591
592
   {
      CacheSPI<Object, Object> cache = createCacheWithListener();
      Set keys;

      TransactionManager mgr = cache.getConfiguration().getRuntimeConfig().getTransactionManager();
      if (mgr.getTransaction() != null) mgr.rollback();
      assertNull(mgr.getTransaction());

      // first put in a value
      mgr.begin();
      assertEquals(0, cache.getTransactionTable().getNumGlobalTransactions());
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
      SamplePojo pojo = new SamplePojo(21, "test");

      cache.put("/one/two", "key1", pojo);

      mgr.rollback();

      assertNull(mgr.getTransaction());
      assertEquals(0, cache.getTransactionTable().getNumGlobalTransactions());
      assertEquals(0, cache.getTransactionTable().getNumLocalTransactions());
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
      SamplePojo pojo = new SamplePojo(21, "test");

      cache.put("/one/two", "key1", pojo);

      assertNotNull(mgr.getTransaction());
      mgr.rollback();

      assertNull(mgr.getTransaction());

      List<?> calls = dummy.getAllCalledIds();
      assertEquals(1, calls.size());
View Full Code Here
170
171
172
173
174
175
176
177
178
179
180
      //start local transaction
      mgr.begin();

      assertNotNull(mgr.getTransaction());
      mgr.rollback();

      assertNull(mgr.getTransaction());

      List<?> calls = dummy.getAllCalled();
      assertEquals(0, calls.size());
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
         assertTrue(!cache.exists("/a/b/c"));
         assertTrue(cache.exists("/a/b/d"));
         dataContainer.printLockInfo();
      }
      catch (Exception ex) {
         tm.rollback();
         throw ex;
      }
      dataContainer.printLockInfo();
      System.out.println(" lock info " + dataContainer.printLockInfo());
      try
View Full Code Here
212
213
214
215
216
217
218
219
220
221
222
      assertEquals(OptimisticPrepareCommand.METHOD_ID, calls.get(0));
      assertEquals(CommitCommand.METHOD_ID, calls.get(1));
      boolean failed = false;
      try
      {
         mgr.rollback();
         fail();
      }
      catch (Exception e)
      {
         failed = true;
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.