execution.addMeasurement(new Measurement("msgsReceivedPerSec", (double)(numMessages * 1000) / result.getTestTime()));
execution.addMeasurement(new Measurement("msgsReceivedPerSec", (double)(numMessages * 1000) / result.testTime));
   public void testQueue16()   {      log.info("Running test Queue16");            //First drain the destination      runJob(createDefaultDrainJob(queueName));      warmupDestination(queueName, standardMessageSize, false, DeliveryMode.NON_PERSISTENT, Session.AUTO_ACKNOWLEDGE);            //Now fill it with numMessages messages      FillJob fillJob = createDefaultFillJob(queueName, numMessages);      fillJob.setDeliveryMode(DeliveryMode.NON_PERSISTENT);      fillJob.setMsgSize(standardMessageSize);      fillJob.setMf(new BytesMessageMessageFactory());      runJob(fillJob);            ReceiverJob receiver = createDefaultReceiverJob(queueName);            //This should always be true      String selector = "JMSMessageID IS NOT NULL AND NonExistentProperty IS NULL";            receiver.setTransacted(false);      receiver.setAckMode(Session.AUTO_ACKNOWLEDGE);      receiver.setSelector(selector);      receiver.setNumMessages(numMessages);            JobTimings result = runJob(receiver);            Execution execution = createExecution("Queue16");            execution.addMeasurement(new Measurement("msgsReceivedPerSec", (double)(numMessages * 1000) / result.getTestTime()));      pm.saveExecution(execution);            log.info("Test Queue16 finished");   }