public void testTopic9()
public void testTopic9() throws PerfException
   public void testTopic9()   {      log.info("Running test Topic9");            //First drain the durable subscription      DrainJob drainJob = createDefaultDrainJob(topicName);      drainJob.setSubName(subscriptionName);      drainJob.setClientID(clientID);      runJob(drainJob);            SenderJob sender = createDefaultSenderJob(topicName);      sender.setNumMessages(numMessages);      sender.setMsgSize(standardMessageSize);      sender.setMf(new TextMessageMessageFactory());      sender.setTransacted(false);      sender.setDeliveryMode(DeliveryMode.PERSISTENT);      sender.setInitialPause(initialPause); //enough time for receiver to get ready      sender.setSlaveURL(slaveURLs[0]);            ReceiverJob receiver = createDefaultReceiverJob(topicName);            receiver.setAckMode(Session.AUTO_ACKNOWLEDGE);      receiver.setTransacted(false);      receiver.setSubName("testSubscription");      receiver.setNumMessages(numMessages);      receiver.setClientID(clientID);      receiver.setSlaveURL(slaveURLs[1]);            JobResult[] results = runJobs(new Job[] {receiver, sender});            if (!checkResults(results, "Topic9"))      {         return;      }            long totalTimeTaken = results[0].endTime - results[1].startTime;            Execution execution = createExecution("Topic9");            execution.addMeasurement(new Measurement("throughput", 1000 * (double)numMessages / totalTimeTaken));      pm.saveExecution(execution);            log.info("Test Topic9 finished");   }