Package org.jboss.cache.transaction

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

133
134
135
136
137
138
139
140
141
142
143
        TransactionWorkspace workspace = entry.getTransactionWorkSpace();

        //assert we can see this with a key value get in the transaction
        assertEquals(0, cache.getChildrenNames("/").size());
        mgr.commit();


        assertTrue(entry.getLocks().isEmpty());
        assertEquals(0, entry.getModifications().size());
        assertTrue(!cache.exists("/one/two"));
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
        mgr.suspend();

        // start a new tx
        mgr.begin();
        Assert.assertEquals(value, cache.get(fqn, key));
        mgr.commit();

        mgr.resume(tx);
        Assert.assertEquals(value, cache.get(fqn, key));
        mgr.commit();
View Full Code Here
66
67
68
69
70
71
72
73
74
75
76
        Assert.assertEquals(value, cache.get(fqn, key));
        mgr.commit();

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

        // cleanup
        loader.remove(fqn);
    }
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
        // test the cache ...
        DummyTransactionManager mgr = DummyTransactionManager.getInstance();
        assertNull(mgr.getTransaction());
        mgr.begin();
        cache.put(fqn, key, value);
        mgr.commit();

        Assert.assertEquals(value, cache.get(fqn, key));

        //now lets see if the state has been persisted in the cache loader
        Assert.assertEquals(value, loader.get(fqn).get(key));
View Full Code Here
93
94
95
96
97
98
99
100
101
102
103
        Assert.assertEquals(value, loader.get(fqn).get(key));


        mgr.begin();
        cache.remove(fqn);
        mgr.commit();

        Assert.assertNull(cache.get(fqn, key));
        //now lets see if the state has been persisted in the cache loader
        Assert.assertNull(loader.get(fqn));
View Full Code Here
109
110
111
112
113
114
115
116
117
118
119
        // lets see what we've got halfway within a tx
        Assert.assertNull(cache.get(fqn, key));
        Assert.assertNull(loader.get(fqn));

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

        // and after committing...
        Assert.assertEquals(value, cache.get(fqn, key));
        Assert.assertEquals(value, loader.get(fqn).get(key));
View Full Code Here
164
165
166
167
168
169
170
171
172
173
174
        Assert.assertNull(loader1.get(fqn));
        Assert.assertNull(loader2.get(fqn));
        Assert.assertNull(cache2.get(fqn, key));

        // commit
        mgr.commit();

        // test that loader1, loader2, cache2 has entry
        Assert.assertEquals(value, cache1.get(fqn, key));
        Assert.assertEquals(value, loader1.get(fqn).get(key));
        Assert.assertEquals(value, loader2.get(fqn).get(key));
View Full Code Here
182
183
184
185
186
187
188
189
190
191
192
        Assert.assertEquals(value, cache1.get(fqn, key));
        Assert.assertEquals(value, loader1.get(fqn).get(key));
        Assert.assertEquals(value, loader2.get(fqn).get(key));

        // commit
        mgr.commit();

        // test that the entry has been removed everywhere.
        Assert.assertNull(cache1.get(fqn));
        Assert.assertNull(loader1.get(fqn));
        Assert.assertNull(loader2.get(fqn));
View Full Code Here
217
218
219
220
221
222
223
224
225
226
227
        Assert.assertNull(loader1.get(fqn));
        Assert.assertNull(loader2.get(fqn));
        Assert.assertNull(cache2.get(fqn, key));

        // commit
        mgr.commit();

        // test that loader1, loader2, cache2 has entry
        Assert.assertEquals(value, cache1.get(fqn, key));
        Assert.assertEquals(value, loader1.get(fqn).get(key));
        Assert.assertEquals(value, loader2.get(fqn).get(key));
View Full Code Here
235
236
237
238
239
240
241
242
243
244
245
        Assert.assertEquals(value, cache1.get(fqn, key));
        Assert.assertEquals(value, loader1.get(fqn).get(key));
        Assert.assertEquals(value, loader2.get(fqn).get(key));

        // commit
        mgr.commit();

        // test that the entry has been removed everywhere.
        Assert.assertNull(cache1.get(fqn));
        Assert.assertNull(loader1.get(fqn));
        Assert.assertNull(loader2.get(fqn));
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.