From 4bf44b728631ce47552fb04fcfeefd2ee1954375 Mon Sep 17 00:00:00 2001
From: Frank Rohde <frank.rohde@tu-dresden.de>
Date: Fri, 22 Oct 2021 10:55:29 +0200
Subject: [PATCH] SensorValueIntegration rejects all mqttMessages while IPos-FW
 is not yet initialized

---
 src/main/java/ipos/project/MainApp.java               |  1 +
 .../api/MqttPositionHandler.java                      | 11 ++++++++++-
 2 files changed, 11 insertions(+), 1 deletion(-)

diff --git a/src/main/java/ipos/project/MainApp.java b/src/main/java/ipos/project/MainApp.java
index c66b05e..3dae0e9 100644
--- a/src/main/java/ipos/project/MainApp.java
+++ b/src/main/java/ipos/project/MainApp.java
@@ -29,6 +29,7 @@ public class MainApp {
         // SimpleSceneIntegration.init();
         SimpleSceneIntegration.init(INDUSTRIEROBOTIK_FILE);
         // SimpleSceneIntegration.init(SENSORDATENFUSION_FILE);
+        ipos.project.SensorValueIntegration.api.MqttPositionHandler.setInitialized(true);
         // GenericSensorValueProcessor.processTestData(TESTDATA_EMPTY);
         // SimpleSceneIntegration.handleMessageFile(TESTDATA_EMPTY);
 	}
diff --git a/src/main/java/ipos/project/SensorValueIntegration/api/MqttPositionHandler.java b/src/main/java/ipos/project/SensorValueIntegration/api/MqttPositionHandler.java
index b12ae6e..6dc3648 100644
--- a/src/main/java/ipos/project/SensorValueIntegration/api/MqttPositionHandler.java
+++ b/src/main/java/ipos/project/SensorValueIntegration/api/MqttPositionHandler.java
@@ -35,12 +35,21 @@ public class MqttPositionHandler implements Handler {
         this.jmsTemplate = jmsTemplate;
     }
 
-   // @Autowired
+    static boolean iposFrameworkIsInitialized = false;
+
+    public static void setInitialized(boolean b) {
+        iposFrameworkIsInitialized = b;
+    }
+
+    // @Autowired
    // private ExternalPubServiceImpl mqttService;
 
     // method that handle new message from the topic
     public void handle(MqttMessage message) {
         try {
+            if (! iposFrameworkIsInitialized){
+                return;
+            }
             SensorEventWrapper protoSensEventWrapper = ProtoJsonMap.fromJson(message.toString(), GenericSensor.SensorEventWrapper.class);
             handleSensorEventWrapper(protoSensEventWrapper);
           } catch (InvalidProtocolBufferException e) {
-- 
GitLab