conn = cf.createConnection(); session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); prod = session.createProducer(queue); prod.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
topic = (Topic)ic.lookup("/topic/Topic");
   public void setUp() throws Exception   {      super.setUp();      ServerManagement.start("all");                  ServerManagement.undeployQueue("Queue");      ServerManagement.deployQueue("Queue");      InitialContext ic = new InitialContext(ServerManagement.getJNDIEnvironment());      cf = (ConnectionFactory)ic.lookup("/ConnectionFactory");      queue = (Queue)ic.lookup("/queue/Queue");      conn = cf.createConnection();      session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);      prod = session.createProducer(queue);      prod.setDeliveryMode(DeliveryMode.NON_PERSISTENT);      log.debug("setup done");   }