while (true) { Message m = queueConsumer.receive(2000); if (m == null) break; }
   public void tearDown() throws Exception   {      // TODO uncomment these      producerConnection.close();      consumerConnection.close();      ServerManagement.undeployQueue("Queue");      ServerManagement.deInit();      super.tearDown();   }