static final int THREADS = 5;
public void testNThreadShutdown() throws Exception{
Channel channel = connection.createChannel();
final QueueingConsumer c = new QueueingConsumer(channel);
channel.queueDeclare(QUEUE, false, true, true, null);
channel.basicConsume(QUEUE, c);
final AtomicInteger count = new AtomicInteger(THREADS);
final CountDownLatch latch = new CountDownLatch(THREADS);
for(int i = 0; i < THREADS; i++){