added

conf/application.conf

@@ -5,6 +5,7 @@ port_no = 5000
 broker = 192.168.0.220
 port = 1883
 time_out = 60
+topic = Website/#
 
 [redis_connection]
 host = 127.0.0.1

scripts/constants/application_config.py

@@ -9,6 +9,7 @@ try:
     broker = config.get("MQTT_Connection", "broker")
     mqtt_port = config.get("MQTT_Connection", "port")
     time_out = config.get("MQTT_Connection", "time_out")
+    topic = config.get("MQTT_Connection", "topic")
 
     host = config.get("redis_connection", "host")
     redis_port = config.get("redis_connection", "redis_port")

scripts/core/handlers/handle_subcribed_data.py

 import json
+
+from scripts.constants.application_config import topic
 from scripts.constants.mqtt_connection import mqtt_client_connection
 from scripts.core.handlers.store_in_redis import store_data_in_db
 from scripts.logging.logger import logger
@@ -16,7 +18,6 @@ def start_subscribing():
         # MQTT client for subscribing
         mqtt_client = mqtt_client_connection()
         print("Waiting for messages")
-        topic = "Website/#"
         mqtt_client.subscribe(topic)
         mqtt_client.on_message = on_message
         mqtt_client.loop_forever()