public void testTopic2()
public void testTopic2() throws PerfException
   public void testTopic2()   {      log.info("Running test Topic2");            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.setNumMessages(numMessages);      receiver.setSlaveURL(slaveURLs[1]);            JobResult[] results = runJobs(new Job[] {receiver, sender});            if (!checkResults(results, "Topic2"))      {         return;      }            long totalTimeTaken = results[0].endTime - results[1].startTime;            Execution execution = createExecution("Topic2");            execution.addMeasurement(new Measurement("throughput", 1000 * (double)numMessages / totalTimeTaken));      pm.saveExecution(execution);            log.info("Test Topic2 finished");   }