log.info("closing connection consumer ...");
log.trace("closing connection consumer ...");
   public void testSimple() throws Exception   {      if (ServerManagement.isRemote()) return;            final int NUM_MESSAGES = 10;            Connection connConsumer = null;            Connection connProducer = null;            try      {         connConsumer = cf.createConnection();                          connConsumer.start();                           Session sessCons = connConsumer.createSession(false, Session.AUTO_ACKNOWLEDGE);                  SimpleMessageListener listener = new SimpleMessageListener(NUM_MESSAGES);                  sessCons.setMessageListener(listener);                  ServerSessionPool pool = new MockServerSessionPool(sessCons);                  JBossConnectionConsumer cc = (JBossConnectionConsumer)connConsumer.createConnectionConsumer(queue, null, pool, 1);                           log.trace("Started connection consumer");                  connProducer = cf.createConnection();                     Session sessProd = connProducer.createSession(false, Session.AUTO_ACKNOWLEDGE);         MessageProducer prod = sessProd.createProducer(queue);                     for (int i = 0; i < NUM_MESSAGES; i++)         {            TextMessage m = sessProd.createTextMessage("testing testing");            prod.send(m);         }                  log.trace("Sent messages");                  //Wait for messages                  listener.waitForLatch(10000);                  if (listener.getMsgsReceived() != NUM_MESSAGES)         {            fail("Didn't receive all messages");         }                  if (listener.failed)         {            fail ("Didn't receive correct messages");         }                  log.info("Received all messages");                  log.info("closing connection consumer ...");                  cc.close();         log.info("closing connections ...");         connProducer.close();         connProducer = null;         connConsumer.close();         connConsumer = null;                   }      finally       {         if (connConsumer != null) connConsumer.close();         if (connConsumer != null) connProducer.close();      }   }