From 8c74cc738f718eec2c5690a4006df17b41d451d1 Mon Sep 17 00:00:00 2001 From: JanardhanBS-SyncByte Date: Fri, 28 Jun 2024 14:48:52 +0530 Subject: [PATCH] [MOSIP-33587] Merge develop from develop-java21 Signed-off-by: JanardhanBS-SyncByte --- .../io/mosip/mock/mv/config/JMSConfig.java | 45 +++++++++++++++++++ 1 file changed, 45 insertions(+) create mode 100644 mock-mv/src/main/java/io/mosip/mock/mv/config/JMSConfig.java diff --git a/mock-mv/src/main/java/io/mosip/mock/mv/config/JMSConfig.java b/mock-mv/src/main/java/io/mosip/mock/mv/config/JMSConfig.java new file mode 100644 index 00000000..e3dd50cf --- /dev/null +++ b/mock-mv/src/main/java/io/mosip/mock/mv/config/JMSConfig.java @@ -0,0 +1,45 @@ +package io.mosip.mock.mv.config; + +import java.util.Arrays; + +import org.apache.activemq.ActiveMQConnectionFactory; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +@Configuration +public class JMSConfig { + private static final Logger logger = LoggerFactory.getLogger(JMSConfig.class); + + /** The Constant FAIL_OVER. */ + private static final String FAIL_OVER = "failover:("; + + /** The Constant RANDOMIZE_FALSE. */ + private static final String RANDOMIZE_FALSE = ")?randomize=false"; + + /** The username. */ + @Value("${registration.processor.manual.adjudication.queue.username}") + private String mausername; + + /** The password. */ + @Value("${registration.processor.manual.adjudication.queue.password}") + private String mapassword; + + /** The URL. */ + @Value("${registration.processor.manual.adjudication.queue.url}") + private String mabrokerUrl; + + @Bean + public ActiveMQConnectionFactory activeMQConnectionFactory() { + logger.info("Creating new connection from configuration."); + String failOverBrokerUrl = FAIL_OVER + mabrokerUrl + "," + mabrokerUrl + RANDOMIZE_FALSE; + logger.info("Broker url : {}", failOverBrokerUrl); + ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(failOverBrokerUrl); + factory.setTrustedPackages(Arrays.asList("io.mosip.mock.mv.*")); + factory.setUserName(mausername); + factory.setPassword(mapassword); + return factory; + } +} \ No newline at end of file