session.close();
   public void testSelectiveClosingConsumer() throws Exception   {      String selector = "color = 'red'";      MessageConsumer redConsumer = session.createConsumer(queue, selector);      conn.start();      Message redMessage = session.createMessage();      redMessage.setStringProperty("color", "red");      Message blueMessage = session.createMessage();      blueMessage.setStringProperty("color", "blue");      prod.send(redMessage);      prod.send(blueMessage);            Message rec = redConsumer.receive();      assertEquals(redMessage.getJMSMessageID(), rec.getJMSMessageID());      assertEquals("red", rec.getStringProperty("color"));            assertNull(redConsumer.receive(3000));            redConsumer.close();            MessageConsumer universalConsumer = session.createConsumer(queue);            rec = universalConsumer.receive();            assertEquals(rec.getJMSMessageID(), blueMessage.getJMSMessageID());      assertEquals("blue", rec.getStringProperty("color"));   }