@@ -68,7 +68,7 @@ public void handleAck(long seqNo,
6868 channel .confirmSelect (true );
6969 channel .queueDeclare ("confirm-test" , true , true , false , null );
7070 channel .basicConsume ("confirm-test" , true , new DefaultConsumer (channel ));
71- channel .queueDeclare ("confirm-test-nondurable" , false , false , false , null );
71+ channel .queueDeclare ("confirm-test-nondurable" , false , true , false , null );
7272 channel .basicConsume ("confirm-test-nondurable" , true ,
7373 new DefaultConsumer (channel ));
7474 channel .queueDeclare ("confirm-test-noconsumer" , true , true , false , null );
@@ -154,11 +154,9 @@ public void testConfirmQueuePurge()
154154 public void testConfirmBasicReject ()
155155 throws IOException , InterruptedException
156156 {
157- System .out .println ("basic.reject test 1" );
158157 basicRejectCommon (false );
159158
160159 waitAcks ();
161- System .out .println ("basic reject test 1 end" );
162160 }
163161
164162 public void testConfirmQueueTTL ()
@@ -243,8 +241,8 @@ private void publish(String exchangeName, String queueName,
243241
244242 private synchronized void gotAckFor (long msgSeqNo ) {
245243 if (!ackSet .contains (msgSeqNo )) {
246- // fail("got duplicate ack: " + msgSeqNo);
247- System .out .println ("got duplicate ack: " + msgSeqNo );
244+ fail ("got duplicate ack: " + msgSeqNo );
245+ // System.out.println("got duplicate ack: " + msgSeqNo);
248246 }
249247 ackSet .remove (msgSeqNo );
250248 }
0 commit comments