Source code: org/activemq/usecases/PersistentDurableTopicSystemTest.java
1 package org.activemq.usecases;
2
3 public class PersistentDurableTopicSystemTest extends SystemTest {
4
5 /**
6 * Sets up the resources of the unit test.
7 *
8 * @throws Exception
9 */
10 protected void setUp() throws Exception {
11 System.out.println("############################################################");
12 System.out.println("PersistentDurableTopicSystemTest.setUp()...");
13 super.setUp();
14 }
15
16 /**
17 * Clears up the resources used in the unit test.
18 */
19 protected void tearDown() throws Exception {
20 System.out.println("PersistentDurableTopicSystemTest.tearDown()...");
21 System.out.println("############################################################");
22 super.tearDown();
23 }
24
25 /**
26 * Unit test for persistent durable topic messages with the following settings:
27 * 1 Producer, 1 Consumer, 1 Subject, 10 Messages
28 *
29 * @throws Exception
30 */
31 public void testPersistentDurableTopicMessageA() throws Exception {
32 SystemTest st = new SystemTest(true,
33 true,
34 true,
35 1,
36 1,
37 1,
38 10,
39 "testPersistentDurableTopicMessageA()");
40 st.doTest();
41 }
42
43 /**
44 * Unit test for persistent durable topic messages with the following settings:
45 * 10 Producers, 10 Consumers, 1 Subject, 10 Messages
46 *
47 * @throws Exception
48 */
49 public void testPersistentDurableTopicMessageB() throws Exception{
50 SystemTest st = new SystemTest(true,
51 true,
52 true,
53 10,
54 10,
55 1,
56 10,
57 "testPersistentDurableTopicMessageB()");
58 st.doTest();
59 }
60
61 /**
62 * Unit test for persistent durable topic messages with the following settings:
63 * 10 Producers, 10 Consumers, 10 Subjects, 10 Messages
64 *
65 * @throws Exception
66 */
67 public void testPersistentDurableTopicMessageC() throws Exception{
68 SystemTest st = new SystemTest(true,
69 true,
70 true,
71 10,
72 10,
73 10,
74 10,
75 "testPersistentDurableTopicMessageC()");
76 st.doTest();
77 }
78 }