execution.addMeasurement(new Measurement("msgsReceivedPerSec", (double)(numMessages * 1000) / result.getTestTime()));
execution.addMeasurement(new Measurement("msgsReceivedPerSec", (double)(numMessages * 1000) / result.testTime));
   public void testQueue11()   {      log.info("Running test Queue11");            //First drain the destination      runJob(createDefaultDrainJob(queueName));      warmupDestination(queueName, standardMessageSize, false, DeliveryMode.PERSISTENT, Session.AUTO_ACKNOWLEDGE);            //Now fill it with numMessages messages      FillJob fillJob = createDefaultFillJob(queueName, numMessages);      fillJob.setDeliveryMode(DeliveryMode.PERSISTENT);      fillJob.setMsgSize(standardMessageSize);      fillJob.setMf(new BytesMessageMessageFactory());      runJob(fillJob);            ReceiverJob receiver = createDefaultReceiverJob(queueName);            receiver.setAckMode(Session.AUTO_ACKNOWLEDGE);      receiver.setTransacted(false);      receiver.setNumMessages(numMessages);            JobTimings result = runJob(receiver);            Execution execution = createExecution("Queue11");            execution.addMeasurement(new Measurement("msgsReceivedPerSec", (double)(numMessages * 1000) / result.getTestTime()));      pm.saveExecution(execution);            log.info("Test Queue11 finished");   }