From 09338c5a3fed6e537bee29805914165a2a2c369d Mon Sep 17 00:00:00 2001
From: Hariharan Anantharaman <hariharan.anantharaman@techolution.com>
Date: Thu, 13 Jun 2019 12:48:16 +0530
Subject: [PATCH] CHanges for AA

---
 .../smartoffice/adapter/MqttkafkaadapterApplication.java  | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/mqttkafkaadapter/src/main/java/com/techolution/smartoffice/adapter/MqttkafkaadapterApplication.java b/mqttkafkaadapter/src/main/java/com/techolution/smartoffice/adapter/MqttkafkaadapterApplication.java
index 98cbca5..9fbb0fb 100644
--- a/mqttkafkaadapter/src/main/java/com/techolution/smartoffice/adapter/MqttkafkaadapterApplication.java
+++ b/mqttkafkaadapter/src/main/java/com/techolution/smartoffice/adapter/MqttkafkaadapterApplication.java
@@ -35,6 +35,10 @@ public class MqttkafkaadapterApplication implements CommandLineRunner{
 	 @Autowired
 	 DefaultMqttCallBack cescMqttCallBack;
 	 
+	 
+	 @Autowired
+	 DefaultMqttCallBack aaMqttCallBack;
+	 
 	 @Autowired
 	 private Environment environment;
 
@@ -56,6 +60,10 @@ public void run(String... args) throws Exception {
 			cescMqttCallBack.connect();
 			logger.debug("Registed cescMqttCallBack callback");
 		}
+		else if((environment.getActiveProfiles())[0].contains("aa")){
+			aaMqttCallBack.connect();
+			logger.debug("Registed cescMqttCallBack callback");
+		}
 		else{
 			smartOfficeMqttCallBack.connect();	
 			logger.debug("Registed smartoffice callback");