@@ -131,7 +131,7 @@ public void testPermutations()
131131 }
132132
133133 public void testFairness ()
134- throws IOException , InterruptedException
134+ throws IOException
135135 {
136136 QueueingConsumer c = new QueueingConsumer (channel );
137137 final int queueCount = 3 ;
@@ -163,7 +163,7 @@ public void testSetLimitAfterConsume()
163163 throws IOException
164164 {
165165 QueueingConsumer c = new QueueingConsumer (channel );
166- String queue = declareBindConsume (c );
166+ declareBindConsume (c );
167167 channel .basicQos (1 );
168168 fill (2 );
169169 //We actually only guarantee that the limit takes effect
@@ -178,19 +178,6 @@ protected void runLimitTests(int limit,
178178 int queueCount )
179179 throws IOException
180180 {
181- try {
182- runLimitTestsHelper (limit , multiAck , txMode , queueCount );
183- } catch (InterruptedException e ) {
184- fail ("interrupted" );
185- }
186- }
187-
188- protected void runLimitTestsHelper (int limit ,
189- boolean multiAck ,
190- boolean txMode ,
191- int queueCount )
192- throws IOException , InterruptedException
193- {
194181
195182 QueueingConsumer c = new QueueingConsumer (channel );
196183
@@ -238,7 +225,7 @@ protected void runLimitTestsHelper(int limit,
238225 }
239226
240227 protected Delivery ack (Queue <Delivery > d , boolean multiAck )
241- throws IOException , InterruptedException
228+ throws IOException
242229 {
243230 Delivery last = null ;
244231
0 commit comments