protected void runMessageTypeJob(Execution execution, MessageFactory mf, String messageType, int type)
protected void runMessageTypeJob(Execution execution, MessageFactory mf, String messageType, int type) throws PerfException
   protected void runMessageTypeJob(Execution execution, MessageFactory mf, String messageType, int type)   {            SenderJob sender = createDefaultSenderJob(queueName);      sender.setNumMessages(numMessages);      sender.setMsgSize(4096);      sender.setMf(mf);      sender.setTransacted(false);      sender.setDeliveryMode(DeliveryMode.PERSISTENT);      sender.setSlaveURL(slaveURLs[0]);            ReceiverJob receiver = createDefaultReceiverJob(queueName);            receiver.setAckMode(Session.AUTO_ACKNOWLEDGE);      receiver.setTransacted(false);      receiver.setSlaveURL(slaveURLs[1]);            JobResult[] results = runJobs(new Job[] {sender, receiver});      long totalTimeTaken = results[1].endTime - results[0].startTime;            Measurement measure = new Measurement("msgsSentPerSec", 1000 * (double)numMessages / totalTimeTaken);            measure.setVariableValue("messageType", (double)type);      execution.addMeasurement(measure);   }