execution.addMeasurement(new Measurement("msgsReceivedPerSec", (double)(numMessages * 1000) / result.testTime));
execution.addMeasurement(new Measurement("msgsReceivedPerSec", (double)(numMessages * 1000) / (result.endTime - result.startTime)));
   public void testQueue16()   {      log.info("Running test Queue16");            //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);            JobResult result = runJob(receiver);            if (!checkResult(result, "Queue16"))      {         return;      }            Execution execution = createExecution("Queue16");            execution.addMeasurement(new Measurement("msgsReceivedPerSec", (double)(numMessages * 1000) / result.testTime));      pm.saveExecution(execution);            log.info("Test Queue16 finished");   }