@@ -119,27 +119,19 @@ public void testNackAll() throws Exception {
119119
120120 byte [] m1 = "1" .getBytes ();
121121 byte [] m2 = "2" .getBytes ();
122- byte [] m3 = "3" .getBytes ();
123- byte [] m4 = "4" .getBytes ();
124122
125123 basicPublishVolatile (m1 , q );
126124 basicPublishVolatile (m2 , q );
127- basicPublishVolatile (m3 , q );
128- basicPublishVolatile (m4 , q );
129125
130126 checkDelivery (channel .basicGet (q , false ), m1 , false );
131127 checkDelivery (channel .basicGet (q , false ), m2 , false );
132- checkDelivery (channel .basicGet (q , false ), m3 , false );
133- checkDelivery (channel .basicGet (q , false ), m4 , false );
134128
135129 // nack all
136130 channel .basicNack (0 , true , true );
137131
138132 QueueingConsumer c = new QueueingConsumer (secondaryChannel );
139133 String consumerTag = secondaryChannel .basicConsume (q , true , c );
140134
141- checkDelivery (c .nextDelivery (), m4 , true );
142- checkDelivery (c .nextDelivery (), m3 , true );
143135 checkDelivery (c .nextDelivery (), m2 , true );
144136 checkDelivery (c .nextDelivery (), m1 , true );
145137
0 commit comments