SenderJob sender = createDefaultSenderJob(testTopicName); sender.setNumMessages(10000); sender.setMsgSize(1024);
SenderJob sender = createDefaultSenderJob(topicName); sender.setNumMessages(numMessages); sender.setMsgSize(standardMessageSize);
   public void testTopic9()   {      log.info("Running test Topic9");            //First drain the durable subscription      DrainJob drainJob = createDefaultDrainJob(testTopicName);      drainJob.setSubName(testSubscriptionName);      runJob(drainJob);            SenderJob sender = createDefaultSenderJob(testTopicName);      sender.setNumMessages(10000);      sender.setMsgSize(1024);      sender.setMf(new BytesMessageMessageFactory());      sender.setTransacted(false);      sender.setDeliveryMode(DeliveryMode.PERSISTENT);            ReceiverJob receiver = createDefaultReceiverJob(testTopicName);            receiver.setAckMode(Session.AUTO_ACKNOWLEDGE);      receiver.setTransacted(false);      receiver.setSubName("testSubscription");            JobTimings[] results = runJobs(new Job[] {sender, receiver});            /*       * NB.       * When we calculating the total time taken from first send to last receive, there is some       * error involved due to the differences in network latency and other remoting overhead       * when sending the jobs to be executed on potentially different remote machines.       * We make the assumption that this this difference is very small compared with time taken       * to run the tests as to be negligible.       */            long totalTimeTaken = results[1].getTestTime() + results[1].getInitTime() - results[0].getInitTime();                  storeResult("Topic9", totalTimeTaken);            log.info("Test Topic9 finished");   }