src/main/java/com/aws/amazonmq/blog/testcases/FIFO_Testcase_6.java [94:166]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - .usingJobData("prefetchSize", prefetchSize).build(); JobDetail job5 = newJob(MsgConsumer_CustomPrefetch.class).withIdentity(useCaseId.concat("-").concat("consumer-job2"), "group1") .usingJobData("consumerName", "consumer_2") .usingJobData("queueName", queueName) .usingJobData("amazonMQSSLEndPoint", amazonMQSSLEndPoint) .usingJobData("username", username) .usingJobData("password", password) .usingJobData("useCaseId", useCaseId) .usingJobData("numMsgs", numMsgs * 4) // this consumer job makes consumer.receive(50); calls 20000 times .usingJobData("prefetchSize", prefetchSize).build(); JobDetail job6 = newJob(MsgConsumer_CustomPrefetch.class).withIdentity(useCaseId.concat("-").concat("consumer-job3"), "group1") .usingJobData("consumerName", "consumer_3") .usingJobData("queueName", queueName) .usingJobData("amazonMQSSLEndPoint", amazonMQSSLEndPoint) .usingJobData("username", username) .usingJobData("password", password) .usingJobData("useCaseId", useCaseId) .usingJobData("numMsgs", numMsgs * 4) // this consumer job makes consumer.receive(50); calls 20000 times .usingJobData("prefetchSize", prefetchSize).build(); // Trigger the jobs Trigger trigger1 = newTrigger().withIdentity("trigger1", "group1").startNow() .withSchedule(simpleSchedule() .withRepeatCount(0)).build(); Trigger trigger2 = newTrigger().withIdentity("trigger2", "group1").startNow() .withSchedule(simpleSchedule() .withRepeatCount(0)) .build(); Trigger trigger3 = newTrigger().withIdentity("trigger3", "group1").startNow() .withSchedule(simpleSchedule() .withRepeatCount(0)).build(); Trigger trigger4 = newTrigger().withIdentity("trigger4", "group1").startNow() .withSchedule(simpleSchedule() .withRepeatCount(0)) .build(); Trigger trigger5 = newTrigger().withIdentity("trigger5", "group1").startNow() .withSchedule(simpleSchedule() .withRepeatCount(0)).build(); Trigger trigger6 = newTrigger().withIdentity("trigger6", "group1").startNow() .withSchedule(simpleSchedule() .withRepeatCount(0)) .build(); logger.info("scheduling producer jobs"); scheduler.scheduleJob(job1, trigger1); scheduler.scheduleJob(job2, trigger2); scheduler.scheduleJob(job3, trigger3); logger.info("scheduling consumer jobs"); logger.info("scheduling the first consumer job"); scheduler.scheduleJob(job4, trigger4); int sleepInterval = 30000; System.out.printf("Main thread sleeping for %d seonds before launching the second consumer. \n", sleepInterval/1000); Thread.sleep(sleepInterval); logger.info("scheduling the second consumer job"); scheduler.scheduleJob(job5, trigger5); System.out.printf("Main thread sleeping for %d seonds before launching the third consumer. \n", sleepInterval/1000); Thread.sleep(sleepInterval); logger.info("scheduling the third consumer job"); scheduler.scheduleJob(job6, trigger6); Thread.sleep(180000 * 2); // Sleep for sometime before shutting down scheduled tasks. 180000 = 3 minutes logger.info("unscheduling jobs and stopping the scheduler. Use case id: " + useCaseId); scheduler.unscheduleJob(trigger1.getKey()); scheduler.unscheduleJob(trigger2.getKey()); scheduler.unscheduleJob(trigger3.getKey()); scheduler.unscheduleJob(trigger4.getKey()); scheduler.unscheduleJob(trigger5.getKey()); scheduler.unscheduleJob(trigger6.getKey()); scheduler.shutdown(); } catch (SchedulerException se) { se.printStackTrace(); - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - src/main/java/com/aws/amazonmq/blog/testcases/FIFO_Testcase_7.java [98:170]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - .usingJobData("prefetchSize", prefetchSize).build(); JobDetail job5 = newJob(MsgConsumer_CustomPrefetch.class).withIdentity(useCaseId.concat("-").concat("consumer-job2"), "group1") .usingJobData("consumerName", "consumer_2") .usingJobData("queueName", queueName) .usingJobData("amazonMQSSLEndPoint", amazonMQSSLEndPoint) .usingJobData("username", username) .usingJobData("password", password) .usingJobData("useCaseId", useCaseId) .usingJobData("numMsgs", numMsgs * 4) // this consumer job makes consumer.receive(50); calls 20000 times .usingJobData("prefetchSize", prefetchSize).build(); JobDetail job6 = newJob(MsgConsumer_CustomPrefetch.class).withIdentity(useCaseId.concat("-").concat("consumer-job3"), "group1") .usingJobData("consumerName", "consumer_3") .usingJobData("queueName", queueName) .usingJobData("amazonMQSSLEndPoint", amazonMQSSLEndPoint) .usingJobData("username", username) .usingJobData("password", password) .usingJobData("useCaseId", useCaseId) .usingJobData("numMsgs", numMsgs * 4) // this consumer job makes consumer.receive(50); calls 20000 times .usingJobData("prefetchSize", prefetchSize).build(); // Trigger the jobs Trigger trigger1 = newTrigger().withIdentity("trigger1", "group1").startNow() .withSchedule(simpleSchedule() .withRepeatCount(0)).build(); Trigger trigger2 = newTrigger().withIdentity("trigger2", "group1").startNow() .withSchedule(simpleSchedule() .withRepeatCount(0)) .build(); Trigger trigger3 = newTrigger().withIdentity("trigger3", "group1").startNow() .withSchedule(simpleSchedule() .withRepeatCount(0)).build(); Trigger trigger4 = newTrigger().withIdentity("trigger4", "group1").startNow() .withSchedule(simpleSchedule() .withRepeatCount(0)) .build(); Trigger trigger5 = newTrigger().withIdentity("trigger5", "group1").startNow() .withSchedule(simpleSchedule() .withRepeatCount(0)).build(); Trigger trigger6 = newTrigger().withIdentity("trigger6", "group1").startNow() .withSchedule(simpleSchedule() .withRepeatCount(0)) .build(); logger.info("scheduling producer jobs"); scheduler.scheduleJob(job1, trigger1); scheduler.scheduleJob(job2, trigger2); scheduler.scheduleJob(job3, trigger3); logger.info("scheduling consumer jobs"); logger.info("scheduling the first consumer job"); scheduler.scheduleJob(job4, trigger4); int sleepInterval = 30000; System.out.printf("Main thread sleeping for %d seonds before launching the second consumer. \n", sleepInterval/1000); Thread.sleep(sleepInterval); logger.info("scheduling the second consumer job"); scheduler.scheduleJob(job5, trigger5); System.out.printf("Main thread sleeping for %d seonds before launching the third consumer. \n", sleepInterval/1000); Thread.sleep(sleepInterval); logger.info("scheduling the third consumer job"); scheduler.scheduleJob(job6, trigger6); Thread.sleep(180000 * 2); // Sleep for sometime before shutting down scheduled tasks. 180000 = 3 minutes logger.info("unscheduling jobs and stopping the scheduler. Use case id: " + useCaseId); scheduler.unscheduleJob(trigger1.getKey()); scheduler.unscheduleJob(trigger2.getKey()); scheduler.unscheduleJob(trigger3.getKey()); scheduler.unscheduleJob(trigger4.getKey()); scheduler.unscheduleJob(trigger5.getKey()); scheduler.unscheduleJob(trigger6.getKey()); scheduler.shutdown(); } catch (SchedulerException se) { se.printStackTrace(); - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -