m = consumer.receive(2000);
m = consumer.receiveNoWait();
	public void testIndividualClientAcknowledge() throws Exception   {				Connection conn = cf.createConnection();     				Session producerSess = conn.createSession(false, Session.CLIENT_ACKNOWLEDGE);		MessageProducer producer = producerSess.createProducer(queue);				Session consumerSess = conn.createSession(false, Session.CLIENT_ACKNOWLEDGE);		MessageConsumer consumer = consumerSess.createConsumer(queue);		conn.start();				final int NUM_MESSAGES = 1;				for (int i = 0; i < NUM_MESSAGES; i++)		{			Message m = producerSess.createMessage();			producer.send(m);		}				log.trace("Sent " + NUM_MESSAGES + " messages");				int count = 0;		while (true)				{			Message m = consumer.receive(500);         log.trace("Received message " + m);			if (m == null)         {            break;         }         log.trace("Acking session");			m.acknowledge();			count++;		}      assertEquals(NUM_MESSAGES, count);      log.trace("received and acknowledged " + count +  " messages");      Message m = consumer.receive(2000);		assertNull(m);            log.trace("mesage is " + m);      log.trace("calling session recover()");		consumerSess.recover();		log.trace("recover called");				m = consumer.receive(2000);		assertNull(m);				conn.close();		   }