3131import java .util .Map ;
3232import java .util .concurrent .TimeoutException ;
3333
34+ import org .junit .Ignore ;
3435import org .junit .Test ;
3536
3637import com .rabbitmq .client .AMQP ;
@@ -119,6 +120,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
119120 drain (c , 2 );
120121 }
121122
123+ @ Ignore
122124 @ Test public void noAckObeysLimit ()
123125 throws IOException
124126 {
@@ -142,6 +144,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
142144 drain (c2 , 1 );
143145 }
144146
147+ @ Ignore
145148 @ Test public void permutations ()
146149 throws IOException
147150 {
@@ -159,6 +162,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
159162 }
160163 }
161164
165+ @ Ignore
162166 @ Test public void fairness ()
163167 throws IOException
164168 {
@@ -188,6 +192,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
188192
189193 }
190194
195+ @ Ignore
191196 @ Test public void singleChannelAndQueueFairness ()
192197 throws IOException
193198 {
@@ -237,6 +242,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
237242 assertTrue (counts .get ("c2" ).intValue () > 0 );
238243 }
239244
245+ @ Ignore
240246 @ Test public void consumerLifecycle ()
241247 throws IOException
242248 {
@@ -258,6 +264,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
258264 channel .queueDelete (queue );
259265 }
260266
267+ @ Ignore
261268 @ Test public void setLimitAfterConsume ()
262269 throws IOException
263270 {
@@ -282,6 +289,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
282289 drain (c , 1 );
283290 }
284291
292+ @ Ignore
285293 @ Test public void limitDecrease ()
286294 throws IOException
287295 {
@@ -302,6 +310,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
302310 drain (c , 2 );
303311 }
304312
313+ @ Ignore
305314 @ Test public void limitingMultipleChannels ()
306315 throws IOException
307316 {
@@ -338,6 +347,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
338347 drain (c , 1 );
339348 }
340349
350+ @ Ignore
341351 @ Test public void recoverReducesLimit () throws Exception {
342352 channel .basicQos (2 , true );
343353 QueueingConsumer c = new QueueingConsumer (channel );
0 commit comments