in MQProducer/src/main/java/com/example/apacheMQLabs/mqProducer.java [52:74]
private void doInit(LambdaLogger logger) {
String rName = System.getenv("AWS_REGION");
Region currentRegion = Region.of(rName);
logger.log("Current Region: " + currentRegion.toString() + " \n");
try {
//Fetch params from SSM
user = getStr("MQ-Username", logger, currentRegion);
logger.log("Username: " + user + " \n");
password = getStr("MQ-Password", logger, currentRegion);
//logger.log("Password: " + password + " \n");
String uri1 = getStr("MQ-Broker1URI", logger, currentRegion);
String uri2 = getStr("MQ-Broker2URI", logger, currentRegion);
//logger.log("Uris: " + uri1 + " & " + uri2 + " \n");
queueName = getStr("MQ-QueueName", logger, currentRegion);
logger.log("Queue: " + queueName + " \n");
//Failover URI
failoverURI = "failover:(" + uri1 + "," + uri2 + ")?randomize=True";
logger.log("Failover URI: " + failoverURI + " \n");
} catch (Exception e) {
logger.log(e.getMessage() + " \n");
System.exit(1); }
}