Feature/fail safe subscription handling (#77)

* Handle FiwareIntegrationLayerException in DataImportEventHandler

Extended subscriptionService.subscribeAndReset with a try/catch block in the handleDataImportEvent function in DataImportEventHandler.java. This update manages potential FiwareIntegrationLayerExceptions that can occur while subscribing to device measurement notifications. Without this update, the system could crash if such exceptions were thrown, leading to user inconvenience.

* Update version in pom.xml

Updated the version of the application in the pom.xml file from 8.0.0 to 8.1.0. This step is necessary for the new release, which includes additional exception handling code in DataImportEventHandler for managing potential FiwareIntegrationLayerExceptions, as these could previously lead to system crashes.

Author: saschadoemer

pom.xml

@@ -14,7 +14,7 @@
 
     <groupId>de.app.5gla</groupId>
     <artifactId>api</artifactId>
-    <version>8.0.0</version>
+    <version>8.1.0</version>
 
     <properties>
         <maven.compiler.source>17</maven.compiler.source>

src/main/java/de/app/fivegla/event/DataImportEventHandler.java

@@ -1,6 +1,7 @@
 package de.app.fivegla.event;
 
 import de.app.fivegla.fiware.SubscriptionService;
+import de.app.fivegla.fiware.api.FiwareIntegrationLayerException;
 import de.app.fivegla.fiware.model.enums.Type;
 import de.app.fivegla.integration.agranimo.AgranimoMeasurementImport;
 import de.app.fivegla.integration.agvolution.AgvolutionMeasurementImport;
@@ -55,8 +56,12 @@ public DataImportEventHandler(SoilScoutMeasurementImport soilScoutMeasurementImp
     public void handleDataImportEvent(DataImportEvent dataImportEvent) {
         log.info("Handling data import event for manufacturer {}.", dataImportEvent.manufacturer());
         if (subscriptionsEnabled) {
-            subscriptionService.subscribeAndReset(Type.DeviceMeasurement);
-            log.info("Subscribed to device measurement notifications.");
+            try {
+                subscriptionService.subscribeAndReset(Type.DeviceMeasurement);
+                log.info("Subscribed to device measurement notifications.");
+            } catch (FiwareIntegrationLayerException e) {
+                log.error("Error subscribing to device measurement notifications.", e);
+            }
         } else {
             log.info("Subscriptions are disabled. Not subscribing to device measurement notifications.");
         }