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");