Merge pull request #16 from openMF/feature/15-Add-username-password-h…

…andling-for-the-message-broker-factory

Add username/password handling for the message broker factory

src/main/java/org/test/consumer/config/MessageConsumerJMSBrokerConfiguration.java

@@ -1,20 +1,34 @@
 package org.test.consumer.config;
 
+
 import org.apache.activemq.ActiveMQConnectionFactory;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.util.StringUtils;
 
 @Configuration
 public class MessageConsumerJMSBrokerConfiguration {
 
     @Value("${brokerurl}")
     private String brokerUrl;
 
+    @Value("${brokerusername")
+    private String brokerUserName;
+
+    @Value("${brokerpassword")
+    private String brokerPassword;
+
     @Bean
     public ActiveMQConnectionFactory connectionFactory() {
         ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
         connectionFactory.setBrokerURL(brokerUrl);
+        if (StringUtils.hasText(brokerUserName)) {
+            connectionFactory.setUserName(brokerUserName);
+        }
+        if (StringUtils.hasText(brokerPassword)) {
+            connectionFactory.setPassword(brokerPassword);
+        }
         connectionFactory.setTrustAllPackages(true);
         return connectionFactory;
     }

src/main/resources/application.properties

@@ -1,5 +1,7 @@
 queuename=${EVENT_QUEUE_NAME:JMS-event-queue}
 brokerurl=${JMS_BROKER_URL:tcp://127.0.0.1:61616}
+brokerusername=${JMS_BROKER_USERNAME:}
+brokerpassword=${JMS_BROKER_PASSWORD:}
 
 spring.datasource.url=jdbc:h2:mem:testdb
 spring.datasource.username=sa