cons.close();
   public void testUnsubscribeDurableSubscription() throws Exception   {      ConnectionFactory cf = (ConnectionFactory)ic.lookup("ConnectionFactory");      Topic topic = (Topic)ic.lookup("/topic/Topic");      Connection conn = cf.createConnection();      conn.setClientID("ak47");      Session s = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);      s.createDurableSubscriber(topic, "uzzi");      MessageProducer prod = s.createProducer(topic);      prod.setDeliveryMode(DeliveryMode.PERSISTENT);      prod.send(s.createTextMessage("one"));      log.debug("unsubscribing ...");      s.unsubscribe("uzzi");      log.debug("resubscribing ...");      MessageConsumer ds = s.createDurableSubscriber(topic, "uzzi");      conn.start();      assertNull(ds.receive(1000));      conn.close();   }