CHanges for AA

Techolution · Jun 13, 2019 · 09338c5 · 09338c5
1 parent 0c9d512
commit 09338c5
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/...dapter/src/main/java/com/techolution/smartoffice/adapter/MqttkafkaadapterApplication.java b/...dapter/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");