src/main/java/com/aws/amazonmq/blog/util/MsgProducer_FIFO.java [39:75]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	public void execute(JobExecutionContext context) throws JobExecutionException {
		// Retrieve job specific settings
		JobKey key = context.getJobDetail().getKey();
		JobDataMap dataMap = context.getJobDetail().getJobDataMap();
		String amazonMQSSLEndpoint = dataMap.getString("amazonMQSSLEndPoint");
		String username = dataMap.getString("username");
		String password = dataMap.getString("password");
		String queueName = dataMap.getString("queueName");
		String producerName = dataMap.getString("producerName");
		String useCaseId = dataMap.getString("useCaseId");
		int numMsgs = dataMap.getInt("numMsgs");
		String msgGroup = dataMap.getString("msgGroup");
		String msgPrefix = dataMap.getString("msgPrefix");
		int msgIdSequence = dataMap.getInt("msgIdSequence");
		System.out.println("Running Job: " + key.getName());
		// Create AmazonMQ connection factory
		ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(amazonMQSSLEndpoint);
		connectionFactory.setUserName(username);
		connectionFactory.setPassword(password);
		try {
			// Create a connection
			long t1 = System.currentTimeMillis();
			Connection connection = connectionFactory.createConnection();
			connection.start();
			long t2 = System.currentTimeMillis();
			System.out.printf("Connection started for %s. It took %d milliseconds. \n", producerName, (t2 - t1));
			t1 = System.currentTimeMillis();
			Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
			Destination producerDestination = session.createQueue(queueName);
			MessageProducer producer = session.createProducer(producerDestination);
			t2 = System.currentTimeMillis();
			System.out.printf("Producer Session for Thread %s Started. It took %d milliseconds \n", producerName,
					(t2 - t1));
			producer.setDeliveryMode(DeliveryMode.PERSISTENT);
			System.out.printf("Writing messages into Amazon MQ. Queue Name: %s, Producer Id: %s, Message Group: %s \n",
					queueName, producerName, msgGroup);
			AtomicInteger counter = new AtomicInteger(msgIdSequence);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/aws/amazonmq/blog/util/MsgProducer_FIFO_Close_Message_Group.java [39:75]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	public void execute(JobExecutionContext context) throws JobExecutionException {
		// Retrieve job specific settings
		JobKey key = context.getJobDetail().getKey();
		JobDataMap dataMap = context.getJobDetail().getJobDataMap();
		String amazonMQSSLEndpoint = dataMap.getString("amazonMQSSLEndPoint");
		String username = dataMap.getString("username");
		String password = dataMap.getString("password");
		String queueName = dataMap.getString("queueName");
		String producerName = dataMap.getString("producerName");
		String useCaseId = dataMap.getString("useCaseId");
		int numMsgs = dataMap.getInt("numMsgs");
		String msgGroup = dataMap.getString("msgGroup");
		String msgPrefix = dataMap.getString("msgPrefix");
		int msgIdSequence = dataMap.getInt("msgIdSequence");
		System.out.println("Running Job: " + key.getName());
		// Create AmazonMQ connection factory
		ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(amazonMQSSLEndpoint);
		connectionFactory.setUserName(username);
		connectionFactory.setPassword(password);
		try {
			// Create a connection
			long t1 = System.currentTimeMillis();
			Connection connection = connectionFactory.createConnection();
			connection.start();
			long t2 = System.currentTimeMillis();
			System.out.printf("Connection started for %s. It took %d milliseconds. \n", producerName, (t2 - t1));
			t1 = System.currentTimeMillis();
			Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
			Destination producerDestination = session.createQueue(queueName);
			MessageProducer producer = session.createProducer(producerDestination);
			t2 = System.currentTimeMillis();
			System.out.printf("Producer Session for Thread %s Started. It took %d milliseconds \n", producerName,
					(t2 - t1));
			producer.setDeliveryMode(DeliveryMode.PERSISTENT);
			System.out.printf("Writing messages into Amazon MQ. Queue Name: %s, Producer Id: %s, Message Group: %s \n",
					queueName, producerName, msgGroup);
			AtomicInteger counter = new AtomicInteger(msgIdSequence);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -