diff --git a/build.gradle b/build.gradle
index 93fc2bd..9c17cee 100644
--- a/build.gradle
+++ b/build.gradle
@@ -60,7 +60,7 @@
             [group: 'org.springframework', name: 'spring-context', version: versions.springcontext],
             [group: 'com.google.code.findbugs', name: 'jsr305', version: versions.findbugs],
             [group: 'org.springframework', name: 'spring-jms', version: versions.springcontext],
-            [group: 'org.apache.activemq', name: 'activemq-spring', version: '5.13.2'],
+            [group: 'org.apache.activemq', name: 'activemq-spring', version: '5.15.9'],
             [group: 'com.google.code.gson', name: 'gson', version: versions.gson],
             [group: 'org.apache.fineract.cn', name: 'lang', version: versions.frameworklangversion],
             [group: 'org.apache.fineract.cn', name: 'async', version: versions.frameworkasyncversion],
diff --git a/src/main/java/org/apache/fineract/cn/command/config/CommandModuleConfiguration.java b/src/main/java/org/apache/fineract/cn/command/config/CommandModuleConfiguration.java
index 287f25e..62725d0 100644
--- a/src/main/java/org/apache/fineract/cn/command/config/CommandModuleConfiguration.java
+++ b/src/main/java/org/apache/fineract/cn/command/config/CommandModuleConfiguration.java
@@ -36,6 +36,8 @@
 import org.springframework.jms.config.DefaultJmsListenerContainerFactory;
 import org.springframework.jms.config.JmsListenerContainerFactory;
 import org.springframework.jms.core.JmsTemplate;
+import org.springframework.util.Assert;
+import org.springframework.util.StringUtils;
 
 @Configuration
 @EnableApplicationName
@@ -71,6 +73,11 @@
         this.environment.getProperty(
             CommandConstants.ACTIVEMQ_BROKER_URL_PROP,
             CommandConstants.ACTIVEMQ_BROKER_URL_DEFAULT));
+    if (!StringUtils.isEmpty(this.environment.getProperty(CommandConstants.ACTIVEMQ_USERNAME))) {
+      Assert.hasLength(this.environment.getProperty(CommandConstants.ACTIVEMQ_PASSWORD),"Amqp password is not supplied");
+      activeMQConnectionFactory.setUserName(this.environment.getProperty(CommandConstants.ACTIVEMQ_USERNAME));
+      activeMQConnectionFactory.setPassword(this.environment.getProperty(CommandConstants.ACTIVEMQ_PASSWORD));
+    }
     pooledConnectionFactory.setConnectionFactory(activeMQConnectionFactory);
     return pooledConnectionFactory;
   }
diff --git a/src/main/java/org/apache/fineract/cn/command/util/CommandConstants.java b/src/main/java/org/apache/fineract/cn/command/util/CommandConstants.java
index 6d2494f..53d04f5 100644
--- a/src/main/java/org/apache/fineract/cn/command/util/CommandConstants.java
+++ b/src/main/java/org/apache/fineract/cn/command/util/CommandConstants.java
@@ -28,6 +28,8 @@
   String APPLICATION_NAME_DEFAULT = "command-v1";
 
   String ACTIVEMQ_BROKER_URL_PROP = "activemq.brokerUrl";
+  String ACTIVEMQ_USERNAME = "activemq.username";
+  String ACTIVEMQ_PASSWORD = "activemq.password";
   String ACTIVEMQ_BROKER_URL_DEFAULT = "vm://localhost?broker.persistent=false";
   String ACTIVEMQ_CONCURRENCY_PROP = "activemq.concurrency";
   String ACTIVEMQ_CONCURRENCY_DEFAULT = "3-10";