31
31
import java .util .Map ;
32
32
import java .util .concurrent .TimeoutException ;
33
33
34
+ import org .junit .Ignore ;
34
35
import org .junit .Test ;
35
36
36
37
import com .rabbitmq .client .AMQP ;
@@ -119,6 +120,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
119
120
drain (c , 2 );
120
121
}
121
122
123
+ @ Ignore
122
124
@ Test public void noAckObeysLimit ()
123
125
throws IOException
124
126
{
@@ -142,6 +144,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
142
144
drain (c2 , 1 );
143
145
}
144
146
147
+ @ Ignore
145
148
@ Test public void permutations ()
146
149
throws IOException
147
150
{
@@ -159,6 +162,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
159
162
}
160
163
}
161
164
165
+ @ Ignore
162
166
@ Test public void fairness ()
163
167
throws IOException
164
168
{
@@ -188,6 +192,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
188
192
189
193
}
190
194
195
+ @ Ignore
191
196
@ Test public void singleChannelAndQueueFairness ()
192
197
throws IOException
193
198
{
@@ -237,6 +242,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
237
242
assertTrue (counts .get ("c2" ).intValue () > 0 );
238
243
}
239
244
245
+ @ Ignore
240
246
@ Test public void consumerLifecycle ()
241
247
throws IOException
242
248
{
@@ -258,6 +264,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
258
264
channel .queueDelete (queue );
259
265
}
260
266
267
+ @ Ignore
261
268
@ Test public void setLimitAfterConsume ()
262
269
throws IOException
263
270
{
@@ -282,6 +289,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
282
289
drain (c , 1 );
283
290
}
284
291
292
+ @ Ignore
285
293
@ Test public void limitDecrease ()
286
294
throws IOException
287
295
{
@@ -302,6 +310,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
302
310
drain (c , 2 );
303
311
}
304
312
313
+ @ Ignore
305
314
@ Test public void limitingMultipleChannels ()
306
315
throws IOException
307
316
{
@@ -338,6 +347,7 @@ public static List<Delivery> drain(QueueingConsumer c, int n)
338
347
drain (c , 1 );
339
348
}
340
349
350
+ @ Ignore
341
351
@ Test public void recoverReducesLimit () throws Exception {
342
352
channel .basicQos (2 , true );
343
353
QueueingConsumer c = new QueueingConsumer (channel );
0 commit comments