this.drainDestination(connFactory, queue);
   public void setUp() throws Exception   {      super.setUp();      ServerManagement.start("all");                  InitialContext ic = new InitialContext(ServerManagement.getJNDIEnvironment());      connFactory = (JBossConnectionFactory)ic.lookup("/ConnectionFactory");      conn = connFactory.createConnection();      session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);      ServerManagement.undeployQueue("Queue");      ServerManagement.deployQueue("Queue");      queue = (Queue)ic.lookup("/queue/Queue");      ServerManagement.undeployTopic("Topic");      ServerManagement.deployTopic("Topic");      topic = (Topic)ic.lookup("/topic/Topic");      queueProd = session.createProducer(queue);      queueCons = session.createConsumer(queue);      conn.start();      ic.close();   }