Package org.jboss.cache.transaction

Examples of org.jboss.cache.transaction.DummyTransactionManager.commit()

111
112
113
114
115
116
117
118
119
120
121
        assertEquals(1, entry.getModifications().size());
        assertTrue(!cache.exists("/one/two"));
        assertEquals(null, dummy.getCalled());


        mgr.commit();

        destroyCache(cache);
    }

    public void testTransactionValidateFailureMethod() throws Exception
View Full Code Here
187
188
189
190
191
192
193
194
195
196
197
        {
            assertTrue(true);
        }


        mgr.commit();

        destroyCache(cache);
    }

    public void testTransactionValidateCommitMethod() throws Exception
View Full Code Here
297
298
299
300
301
302
303
304
305
306
307
        assertTrue(cache.exists(node.getFqn()));
        assertEquals(new DefaultDataVersion(1), node.getVersion());

        assertEquals(pojo, node.get("key1"));

        mgr.commit();

        destroyCache(cache);
    }

View Full Code Here
404
405
406
407
408
409
410
411
412
413
414
        assertTrue(cache.exists(node.getFqn()));
        assertEquals(new DefaultDataVersion(1), node.getVersion());

        assertEquals(pojo, node.get("key1"));

        mgr.commit();

        destroyCache(cache);
    }

    public void testTransactionValidateRollbackMethod() throws Exception
View Full Code Here
494
495
496
497
498
499
500
501
502
503
504
        assertNull(workspace.getNode(Fqn.fromString("/one/two")));
        assertNull(workspace.getNode(Fqn.fromString("/one")));
        assertTrue(entry.getLocks().isEmpty());
        assertEquals(1, entry.getModifications().size());

        mgr.commit();

        destroyCache(cache);
    }

}
View Full Code Here
308
309
310
311
312
313
314
315
316
317
318
        OptimisticTransactionEntry entry2 = (OptimisticTransactionEntry) table.get(gtx2);

        TransactionWorkspace workspace2 = entry2.getTransactionWorkSpace();

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

        //assert that our keys are in one space
        assertEquals(3, workspace.getNodes().size());
View Full Code Here
310
311
312
313
314
315
316
317
318
319
320
        TransactionWorkspace workspace2 = entry2.getTransactionWorkSpace();

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

        //assert that our keys are in one space
        assertEquals(3, workspace.getNodes().size());
        assertNotNull(workspace.getNode(Fqn.fromString("/one/two")));
        assertEquals(pojo, workspace.getNode(Fqn.fromString("/one/two")).get("key1"));
View Full Code Here
46
47
48
49
50
51
52
53
54
55
56
        cache.put("/one/two", "key1", pojo);

        //GlobalTransaction gtx = cache.getCurrentTransaction(tx);
        TransactionTable table = cache.getTransactionTable();
        assertNotNull(mgr.getTransaction());
        mgr.commit();


        assertNull(mgr.getTransaction());

        //assert that the local cache is in the right state
View Full Code Here
98
99
100
101
102
103
104
105
106
107
108
        cache.put("/one/two", "key1", pojo);

        GlobalTransaction gtx = cache.getCurrentTransaction(tx);
        TransactionTable table = cache.getTransactionTable();
        assertNotNull(mgr.getTransaction());
        mgr.commit();


        assertNull(mgr.getTransaction());

        //assert that the local cache is in the right state
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
        OptimisticTransactionEntry entry = (OptimisticTransactionEntry) table.get(gtx);

        TransactionWorkspace workspace = entry.getTransactionWorkSpace();

        mgr.commit();

        //assert what should be the results of our call
        assertEquals(3, workspace.getNodes().size());
        assertNotNull(workspace.getNode(Fqn.fromString("/one/two")));
        assertEquals(pojo, workspace.getNode(Fqn.fromString("/one/two")).get("key1"));
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.