ignore first value and use transaction

AndreKoepke · Dec 2, 2024 · 11e689e · 11e689e
1 parent 88fe67a
commit 11e689e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/backend/src/main/java/ch/akop/homesystem/services/impl/MotionSensorService.java b/backend/src/main/java/ch/akop/homesystem/services/impl/MotionSensorService.java
@@ -9,6 +9,7 @@
 import ch.akop.homesystem.persistence.repository.config.MotionSensorConfigRepository;
 import ch.akop.homesystem.states.NormalState;
 import ch.akop.homesystem.states.SleepState;
+import io.quarkus.narayana.jta.QuarkusTransaction;
 import io.reactivex.rxjava3.core.Observable;
 import io.reactivex.rxjava3.schedulers.Schedulers;
 import io.vertx.core.Vertx;
@@ -91,8 +92,9 @@ private List<SimpleLight> resolveLights() {
 
     public void startListing() {
       stateService.getCurrrentState$()
+          .skip(1)
           .subscribeOn(RxHelper.blockingScheduler(vertx, false))
-          .subscribe(newState -> this.referencedLights = resolveLights());
+          .subscribe(newState -> QuarkusTransaction.requiringNew().run(() -> this.referencedLights = resolveLights()));
 
       sensor.getIsMoving$()
           .subscribeOn(Schedulers.io())