|
1
22 package org.jboss.test.txtimer.test;
23
24 import java.util.List  ;
25
26 import javax.management.MBeanServerInvocationHandler ;
27 import javax.naming.InitialContext ;
28
29 import junit.framework.TestSuite;
30
31 import org.jboss.ejb.txtimer.DatabasePersistencePolicyMBean;
32 import org.jboss.test.JBossTestCase;
33 import org.jboss.test.txtimer.interfaces.TimerTest;
34 import org.jboss.test.txtimer.interfaces.TimerTestHome;
35
36
42 public class CreateCancelTestCase extends JBossTestCase
43 {
44 DatabasePersistencePolicyMBean pp;
45
46 public CreateCancelTestCase(String name)
47 {
48 super(name);
49 }
50
51 protected void setUp() throws Exception
52 {
53 super.setUp();
54 pp = (DatabasePersistencePolicyMBean) MBeanServerInvocationHandler.newProxyInstance(
55 getServer(), DatabasePersistencePolicyMBean.OBJECT_NAME, DatabasePersistencePolicyMBean.class, false);
56 }
57
58 protected int getTimerCount()
59 {
60 List timerHandles = pp.listTimerHandles();
61 return timerHandles.size();
62 }
63
64 public static TestSuite suite() throws Exception
65 {
66 TestSuite ts = new TestSuite();
67 ts.addTest(getDeploySetup(CreateCancelTestCase.class, "ejb-txtimer.jar"));
68 return ts;
69 }
70
71 public void testCreateRequiredCancelRequired() throws Exception
72 {
73 InitialContext iniCtx = getInitialContext();
74 TimerTestHome home = (TimerTestHome) iniCtx.lookup(TimerTestHome.JNDI_NAME);
75 TimerTest session = home.create();
76
77 try
78 {
79 int initialTimerCount;
80 int createdTimerCount;
81 int canceledTimerCount;
82
83 initialTimerCount = getTimerCount();
84 session.startTimerInTxRequired();
85 createdTimerCount = getTimerCount();
86 assertEquals("Timer not created", initialTimerCount + 1, createdTimerCount);
87 session.cancelTimerInTxRequired();
88 canceledTimerCount = getTimerCount();
89 assertEquals("Timer not canceled", createdTimerCount, canceledTimerCount + 1);
90 }
91 finally
92 {
93 session.remove();
94 }
95 }
96
97 public void testCreateRequiredCancelRequiresNew() throws Exception
98 {
99 InitialContext iniCtx = getInitialContext();
100 TimerTestHome home = (TimerTestHome) iniCtx.lookup(TimerTestHome.JNDI_NAME);
101 TimerTest session = home.create();
102
103 try
104 {
105 int initialTimerCount;
106 int createdTimerCount;
107 int canceledTimerCount;
108
109 initialTimerCount = getTimerCount();
110 session.startTimerInTxRequired();
111 createdTimerCount = getTimerCount();
112 assertEquals("Timer not created", initialTimerCount + 1, createdTimerCount);
113 session.cancelTimerInTxRequiresNew();
114 canceledTimerCount = getTimerCount();
115 assertEquals("Timer not canceled", createdTimerCount, canceledTimerCount + 1);
116 }
117 finally
118 {
119 session.remove();
120 }
121 }
122
123 public void testCreateRequiredCancelNotSupported() throws Exception
124 {
125 InitialContext iniCtx = getInitialContext();
126 TimerTestHome home = (TimerTestHome) iniCtx.lookup(TimerTestHome.JNDI_NAME);
127 TimerTest session = home.create();
128
129 try
130 {
131 int initialTimerCount;
132 int createdTimerCount;
133 int canceledTimerCount;
134
135 initialTimerCount = getTimerCount();
136 session.startTimerInTxRequired();
137 createdTimerCount = getTimerCount();
138 assertEquals("Timer not created", initialTimerCount + 1, createdTimerCount);
139 session.cancelTimerInTxNotSupported();
140 canceledTimerCount = getTimerCount();
141 assertEquals("Timer not canceled", createdTimerCount, canceledTimerCount + 1);
142 }
143 finally
144 {
145 session.remove();
146 }
147 }
148
149 public void testCreateRequiredCancelNever() throws Exception
150 {
151 InitialContext iniCtx = getInitialContext();
152 TimerTestHome home = (TimerTestHome) iniCtx.lookup(TimerTestHome.JNDI_NAME);
153 TimerTest session = home.create();
154
155 try
156 {
157 int initialTimerCount;
158 int createdTimerCount;
159 int canceledTimerCount;
160
161 initialTimerCount = getTimerCount();
162 session.startTimerInTxRequired();
163 createdTimerCount = getTimerCount();
164 assertEquals("Timer not created", initialTimerCount + 1, createdTimerCount);
165 session.cancelTimerInTxNever();
166 canceledTimerCount = getTimerCount();
167 assertEquals("Timer not canceled", createdTimerCount, canceledTimerCount + 1);
168 }
169 finally
170 {
171 session.remove();
172 }
173 }
174
175 public void testCreateRequiresNewCancelRequired() throws Exception
176 {
177 InitialContext iniCtx = getInitialContext();
178 TimerTestHome home = (TimerTestHome) iniCtx.lookup(TimerTestHome.JNDI_NAME);
179 TimerTest session = home.create();
180
181 try
182 {
183 int initialTimerCount;
184 int createdTimerCount;
185 int canceledTimerCount;
186
187 initialTimerCount = getTimerCount();
188 session.startTimerInTxRequiresNew();
189 createdTimerCount = getTimerCount();
190 assertEquals("Timer not created", initialTimerCount + 1, createdTimerCount);
191 session.cancelTimerInTxRequired();
192 canceledTimerCount = getTimerCount();
193 assertEquals("Timer not canceled", createdTimerCount, canceledTimerCount + 1);
194 }
195 finally
196 {
197 session.remove();
198 }
199 }
200
201 public void testCreateRequiresNewCancelRequiresNew() throws Exception
202 {
203 InitialContext iniCtx = getInitialContext();
204 TimerTestHome home = (TimerTestHome) iniCtx.lookup(TimerTestHome.JNDI_NAME);
205 TimerTest session = home.create();
206
207 try
208 {
209 int initialTimerCount;
210 int createdTimerCount;
211 int canceledTimerCount;
212
213 initialTimerCount = getTimerCount();
214 session.startTimerInTxRequiresNew();
215 createdTimerCount = getTimerCount();
216 assertEquals("Timer not created", initialTimerCount + 1, createdTimerCount);
217 session.cancelTimerInTxRequiresNew();
218 canceledTimerCount = getTimerCount();
219 assertEquals("Timer not canceled", createdTimerCount, canceledTimerCount + 1);
220 }
221 finally
222 {
223 session.remove();
224 }
225 }
226
227 public void testCreateRequiresNewCancelNotSupported() throws Exception
228 {
229 InitialContext iniCtx = getInitialContext();
230 TimerTestHome home = (TimerTestHome) iniCtx.lookup(TimerTestHome.JNDI_NAME);
231 TimerTest session = home.create();
232
233 try
234 {
235 int initialTimerCount;
236 int createdTimerCount;
237 int canceledTimerCount;
238
239 initialTimerCount = getTimerCount();
240 session.startTimerInTxRequiresNew();
241 createdTimerCount = getTimerCount();
242 assertEquals("Timer not created", initialTimerCount + 1, createdTimerCount);
243 session.cancelTimerInTxNotSupported();
244 canceledTimerCount = getTimerCount();
245 assertEquals("Timer not canceled", createdTimerCount, canceledTimerCount + 1);
246 }
247 finally
248 {
249 session.remove();
250 }
251 }
252
253 public void testCreateRequiresNewCancelNever() throws Exception
254 {
255 InitialContext iniCtx = getInitialContext();
256 TimerTestHome home = (TimerTestHome) iniCtx.lookup(TimerTestHome.JNDI_NAME);
257 TimerTest session = home.create();
258
259 try
260 {
261 int initialTimerCount;
262 int createdTimerCount;
263 int canceledTimerCount;
264
265 initialTimerCount = getTimerCount();
266 session.startTimerInTxRequiresNew();
267 createdTimerCount = getTimerCount();
268 assertEquals("Timer not created", initialTimerCount + 1, createdTimerCount);
269 session.cancelTimerInTxNever();
270 canceledTimerCount = getTimerCount();
271 assertEquals("Timer not canceled", createdTimerCount, canceledTimerCount + 1);
272 }
273 finally
274 {
275 session.remove();
276 }
277 }
278
279 public void testCreateNotSupportedCancelRequired() throws Exception
280 {
281 InitialContext iniCtx = getInitialContext();
282 TimerTestHome home = (TimerTestHome) iniCtx.lookup(TimerTestHome.JNDI_NAME);
283 TimerTest session = home.create();
284
285 try
286 {
287 int initialTimerCount;
288 int createdTimerCount;
289 int canceledTimerCount;
290
291 initialTimerCount = getTimerCount();
292 session.startTimerInTxNotSupported();
293 createdTimerCount = getTimerCount();
294 assertEquals("Timer not created", initialTimerCount + 1, createdTimerCount);
295 session.cancelTimerInTxRequired();
296 canceledTimerCount = getTimerCount();
297 assertEquals("Timer not canceled", createdTimerCount, canceledTimerCount + 1);
298 }
299 finally
300 {
301 session.remove();
302 }
303 }
304
305 public void testCreateNotSupportedCancelRequiresNew() throws Exception
306 {
307 InitialContext iniCtx = getInitialContext();
308 TimerTestHome home = (TimerTestHome) iniCtx.lookup(TimerTestHome.JNDI_NAME);
309 TimerTest session = home.create();
310
311 try
312 {
313 int initialTimerCount;
314 int createdTimerCount;
315 int canceledTimerCount;
316
317 initialTimerCount = getTimerCount();
318 session.startTimerInTxNotSupported();
319 createdTimerCount = getTimerCount();
320 assertEquals("Timer not created", initialTimerCount + 1, createdTimerCount);
321 session.cancelTimerInTxRequiresNew();
322 canceledTimerCount = getTimerCount();
323 assertEquals("Timer not canceled", createdTimerCount, canceledTimerCount + 1);
324 }
325 finally
326 {
327 session.remove();
328 }
329 }
330
331 public void testCreateNotSupportedCancelNotSupported() throws Exception
332 {
333 InitialContext iniCtx = getInitialContext();
334 TimerTestHome home = (TimerTestHome) iniCtx.lookup(TimerTestHome.JNDI_NAME);
335 TimerTest session = home.create();
336
337 try
338 {
339 int initialTimerCount;
340 int createdTimerCount;
341 int canceledTimerCount;
342
343 initialTimerCount = getTimerCount();
344 session.startTimerInTxNotSupported();
345 createdTimerCount = getTimerCount();
346 assertEquals("Timer not created", initialTimerCount + 1, createdTimerCount);
347 session.cancelTimerInTxNotSupported();
348 canceledTimerCount = getTimerCount();
349 assertEquals("Timer not canceled", createdTimerCount, canceledTimerCount + 1);
350 }
351 finally
352 {
353 session.remove();
354 }
355 }
356
357 public void testCreateNotSupportedCancelNever() throws Exception
358 {
359 InitialContext iniCtx = getInitialContext();
360 TimerTestHome home = (TimerTestHome) iniCtx.lookup(TimerTestHome.JNDI_NAME);
361 TimerTest session = home.create();
362
363 try
364 {
365 int initialTimerCount;
366 int createdTimerCount;
367 int canceledTimerCount;
368
369 initialTimerCount = getTimerCount();
370 session.startTimerInTxNotSupported();
371 createdTimerCount = getTimerCount();
372 assertEquals("Timer not created", initialTimerCount + 1, createdTimerCount);
373 session.cancelTimerInTxNever();
374 canceledTimerCount = getTimerCount();
375 assertEquals("Timer not canceled", createdTimerCount, canceledTimerCount + 1);
376 }
377 finally
378 {
379 session.remove();
380 }
381 }
382
383 public void testCreateNeverCancelRequired() throws Exception
384 {
385 InitialContext iniCtx = getInitialContext();
386 TimerTestHome home = (TimerTestHome) iniCtx.lookup(TimerTestHome.JNDI_NAME);
387 TimerTest session = home.create();
388
389 try
390 {
391 int initialTimerCount;
392 int createdTimerCount;
393 int canceledTimerCount;
394
395 initialTimerCount = getTimerCount();
396 session.startTimerInTxNever();
397 createdTimerCount = getTimerCount();
398 assertEquals("Timer not created", initialTimerCount + 1, createdTimerCount);
399 session.cancelTimerInTxRequired();
400 canceledTimerCount = getTimerCount();
401 assertEquals("Timer not canceled", createdTimerCount, canceledTimerCount + 1);
402 }
403 finally
404 {
405 session.remove();
406 }
407 }
408
409 public void testCreateNeverCancelRequiresNew() throws Exception
410 {
411 InitialContext iniCtx = getInitialContext();
412 TimerTestHome home = (TimerTestHome) iniCtx.lookup(TimerTestHome.JNDI_NAME);
413 TimerTest session = home.create();
414
415 try
416 {
417 int initialTimerCount;
418 int createdTimerCount;
419 int canceledTimerCount;
420
421 initialTimerCount = getTimerCount();
422 session.startTimerInTxNever();
423 createdTimerCount = getTimerCount();
424 assertEquals("Timer not created", initialTimerCount + 1, createdTimerCount);
425 session.cancelTimerInTxRequiresNew();
426 canceledTimerCount = getTimerCount();
427 assertEquals("Timer not canceled", createdTimerCount, canceledTimerCount + 1);
428 }
429 finally
430 {
431 session.remove();
432 }
433 }
434
435 public void testCreateNeverCancelNotSupported() throws Exception
436 {
437 InitialContext iniCtx = getInitialContext();
438 TimerTestHome home = (TimerTestHome) iniCtx.lookup(TimerTestHome.JNDI_NAME);
439 TimerTest session = home.create();
440
441 try
442 {
443 int initialTimerCount;
444 int createdTimerCount;
445 int canceledTimerCount;
446
447 initialTimerCount = getTimerCount();
448 session.startTimerInTxNever();
449 createdTimerCount = getTimerCount();
450 assertEquals("Timer not created", initialTimerCount + 1, createdTimerCount);
451 session.cancelTimerInTxNotSupported();
452 canceledTimerCount = getTimerCount();
453 assertEquals("Timer not canceled", createdTimerCount, canceledTimerCount + 1);
454 }
455 finally
456 {
457 session.remove();
458 }
459 }
460
461 public void testCreateNeverCancelNever() throws Exception
462 {
463 InitialContext iniCtx = getInitialContext();
464 TimerTestHome home = (TimerTestHome) iniCtx.lookup(TimerTestHome.JNDI_NAME);
465 TimerTest session = home.create();
466
467 try
468 {
469 int initialTimerCount;
470 int createdTimerCount;
471 int canceledTimerCount;
472
473 initialTimerCount = getTimerCount();
474 session.startTimerInTxNever();
475 createdTimerCount = getTimerCount();
476 assertEquals("Timer not created", initialTimerCount + 1, createdTimerCount);
477 session.cancelTimerInTxNever();
478 canceledTimerCount = getTimerCount();
479 assertEquals("Timer not canceled", createdTimerCount, canceledTimerCount + 1);
480 }
481 finally
482 {
483 session.remove();
484 }
485 }
486
487 }
488 |
Popular Tags |
Java API By Example, From Geeks To Geeks.