@@ -69,48 +69,48 @@ public void testSingleNack() throws Exception {
6969 expectError (AMQP .PRECONDITION_FAILED );
7070 }
7171
72- public void testMultiNack () throws Exception {
73- String q =
74- channel .queueDeclare ("" , false , true , false , null ).getQueue ();
72+ public void testMultiNack () throws Exception {
73+ String q =
74+ channel .queueDeclare ("" , false , true , false , null ).getQueue ();
7575
76- byte [] m1 = "1" .getBytes ();
77- byte [] m2 = "2" .getBytes ();
78- byte [] m3 = "3" .getBytes ();
79- byte [] m4 = "4" .getBytes ();
76+ byte [] m1 = "1" .getBytes ();
77+ byte [] m2 = "2" .getBytes ();
78+ byte [] m3 = "3" .getBytes ();
79+ byte [] m4 = "4" .getBytes ();
8080
81- basicPublishVolatile (m1 , q );
82- basicPublishVolatile (m2 , q );
83- basicPublishVolatile (m3 , q );
84- basicPublishVolatile (m4 , q );
81+ basicPublishVolatile (m1 , q );
82+ basicPublishVolatile (m2 , q );
83+ basicPublishVolatile (m3 , q );
84+ basicPublishVolatile (m4 , q );
8585
86- checkDelivery (channel .basicGet (q , false ), m1 , false );
87- long tag1 = checkDelivery (channel .basicGet (q , false ), m2 , false );
88- checkDelivery (channel .basicGet (q , false ), m3 , false );
89- long tag2 = checkDelivery (channel .basicGet (q , false ), m4 , false );
86+ checkDelivery (channel .basicGet (q , false ), m1 , false );
87+ long tag1 = checkDelivery (channel .basicGet (q , false ), m2 , false );
88+ checkDelivery (channel .basicGet (q , false ), m3 , false );
89+ long tag2 = checkDelivery (channel .basicGet (q , false ), m4 , false );
9090
91- // ack, leaving a gap in un-acked sequence
92- channel .basicAck (tag1 , false );
91+ // ack, leaving a gap in un-acked sequence
92+ channel .basicAck (tag1 , false );
9393
94- QueueingConsumer c = new QueueingConsumer (secondaryChannel );
95- String consumerTag = secondaryChannel .basicConsume (q , false , c );
94+ QueueingConsumer c = new QueueingConsumer (secondaryChannel );
95+ String consumerTag = secondaryChannel .basicConsume (q , false , c );
9696
97- // requeue multi
98- channel .basicNack (tag2 , true , true );
97+ // requeue multi
98+ channel .basicNack (tag2 , true , true );
9999
100- checkDelivery (c .nextDelivery (), m4 , true );
101- checkDelivery (c .nextDelivery (), m3 , true );
102- long tag3 = checkDelivery (c .nextDelivery (), m1 , true );
100+ checkDelivery (c .nextDelivery (), m4 , true );
101+ checkDelivery (c .nextDelivery (), m3 , true );
102+ long tag3 = checkDelivery (c .nextDelivery (), m1 , true );
103103
104- secondaryChannel .basicCancel (consumerTag );
104+ secondaryChannel .basicCancel (consumerTag );
105105
106- // no requeue
107- secondaryChannel .basicNack (tag3 , true , false );
106+ // no requeue
107+ secondaryChannel .basicNack (tag3 , true , false );
108108
109- assertNull (channel .basicGet (q , false ));
109+ assertNull (channel .basicGet (q , false ));
110110
111- channel .basicNack (tag3 , true , true );
111+ channel .basicNack (tag3 , true , true );
112112
113- expectError (AMQP .PRECONDITION_FAILED );
114- }
113+ expectError (AMQP .PRECONDITION_FAILED );
114+ }
115115
116116}
0 commit comments