diff --git a/api-customer/app.py b/api-customer/app.py index a1e160fa..6beb6221 100644 --- a/api-customer/app.py +++ b/api-customer/app.py @@ -1,6 +1,7 @@ import os import threading +import requests from dotenv import load_dotenv from flask import Flask @@ -29,7 +30,11 @@ message_controller = MessageController(app, auth_data, "https://192.168.15.120:8 def handle_message_received(topic:str, payload:str): - pass + try : + url = "https://127.0.0.1:1880/message/receive" + requests.post(url, json=payload, verify=False) + except Exception as e: + print(e) def start_mqtt(data : AuthData): client_id = data.get_client_id()