@@ -76,32 +76,39 @@ private void declareBindQueue(String queueName, boolean durable)
7676 channel .queueBind (queueName , "amq.direct" , "confirm-multiple-queues" );
7777 }
7878
79- public void testPersistentMandatory ()
79+ public void testTransient ()
8080 throws Exception
8181 {
8282 declareConsumeQueue ("confirm-test" , true );
83- confirmTest ("" , "confirm-test" , true , true , false );
83+ confirmTest ("" , "confirm-test" , false , false , false );
8484 }
8585
86- public void testTransient ()
86+ public void testPersistentSimple ()
8787 throws Exception
8888 {
8989 declareConsumeQueue ("confirm-test" , true );
90- confirmTest ("" , "confirm-test" , false , false , false );
90+ confirmTest ("" , "confirm-test" , true , false , false );
9191 }
9292
93- public void testPersistentSimple ()
93+ public void testTransientMandatory ()
9494 throws Exception
9595 {
9696 declareConsumeQueue ("confirm-test" , true );
97- confirmTest ("" , "confirm-test" , true , false , false );
97+ confirmTest ("" , "confirm-test" , false , true , false );
9898 }
9999
100- public void testNonDurable ()
100+ public void testPersistentMandatory ()
101101 throws Exception
102102 {
103- declareConsumeQueue ("confirm-test-nondurable" , false );
104- confirmTest ("" , "confirm-test-nondurable" , true , false , false );
103+ declareConsumeQueue ("confirm-test" , true );
104+ confirmTest ("" , "confirm-test" , true , true , false );
105+ }
106+
107+ public void testTransientImmediate ()
108+ throws Exception
109+ {
110+ declareConsumeQueue ("confirm-test" , true );
111+ confirmTest ("" , "confirm-test" , false , false , true );
105112 }
106113
107114 public void testPersistentImmediate ()
@@ -111,6 +118,27 @@ public void testPersistentImmediate()
111118 confirmTest ("" , "confirm-test" , true , false , true );
112119 }
113120
121+ public void testTransientMandatoryImmediate ()
122+ throws Exception
123+ {
124+ declareConsumeQueue ("confirm-test" , true );
125+ confirmTest ("" , "confirm-test" , false , true , true );
126+ }
127+
128+ public void testPersistentMandatoryImmediate ()
129+ throws Exception
130+ {
131+ declareConsumeQueue ("confirm-test" , true );
132+ confirmTest ("" , "confirm-test" , true , true , true );
133+ }
134+
135+ public void testNonDurable ()
136+ throws Exception
137+ {
138+ declareConsumeQueue ("confirm-test-nondurable" , false );
139+ confirmTest ("" , "confirm-test-nondurable" , true , false , false );
140+ }
141+
114142 public void testPersistentImmediateNoConsumer ()
115143 throws Exception
116144 {
0 commit comments