@@ -65,6 +65,9 @@ public void handleAck(long seqNo,
6565 channel .confirmSelect (true );
6666 channel .queueDeclare ("confirm-test" , true , true , true , null );
6767 channel .basicConsume ("confirm-test" , true , new DefaultConsumer (channel ));
68+ channel .queueDeclare ("confirm-test-nondurable" , false , false , true , null );
69+ channel .basicConsume ("confirm-test-nondurable" , true ,
70+ new DefaultConsumer (channel ));
6871 channel .queueDeclare ("confirm-test-noconsumer" , true , true , true , null );
6972 channel .queueDeclare ("confirm-test-2" , true , true , true , null );
7073 channel .basicConsume ("confirm-test-2" , true , new DefaultConsumer (channel ));
@@ -82,6 +85,12 @@ public void testConfirmPersistentSimple()
8285 confirmTest ("confirm-test" , true , false , false );
8386 }
8487
88+ public void testConfirmNonDurable ()
89+ throws IOException , InterruptedException
90+ {
91+ confirmTest ("confirm-test-nondurable" , true , false , false );
92+ }
93+
8594 public void testConfirmPersistentImmediate ()
8695 throws IOException , InterruptedException
8796 {
0 commit comments