diff --git a/src/main/java/ipos/project/MainApp.java b/src/main/java/ipos/project/MainApp.java
index c66b05ec70cb513a96e37747a9bfda833c7ed78a..3dae0e9aab7432f936cacff9c130cff6d3c486f8 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 b12ae6eab46ba11f88db16634066057b11374c37..6dc364872cf871fe02aeb91c77ced4e966fa475d 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) {