do not sync things without a policyId

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
eclipse-ditto · Jun 1, 2022 · e4d1492 · e4d1492
1 parent 7d0adb2
commit e4d1492
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/...g/eclipse/ditto/thingsearch/service/persistence/write/streaming/BackgroundSyncStream.java b/...g/eclipse/ditto/thingsearch/service/persistence/write/streaming/BackgroundSyncStream.java
@@ -192,8 +192,8 @@ private Source<Metadata, NotUsed> emitUnlessConsistent(final Metadata persisted,
                             );
             return Source.completionStageSource(askFuture);
         } else {
-            // policy ID does not exist: entry should be updated in search index
-            return Source.single(persisted);
+            // policy ID does not exist: entry should not be updated in search index
+            return Source.empty();
         }
     }
 

diff --git a/...c/main/java/org/eclipse/ditto/thingsearch/service/updater/actors/BackgroundSyncActor.java b/...c/main/java/org/eclipse/ditto/thingsearch/service/updater/actors/BackgroundSyncActor.java
@@ -119,8 +119,7 @@ public static Props props(final BackgroundSyncConfig config,
     @Override
     protected void preEnhanceSleepingBehavior(final ReceiveBuilder sleepingReceiveBuilder) {
         sleepingReceiveBuilder.matchEquals(Control.BOOKMARK_THING_ID,
-                        trigger ->
-                                // ignore scheduled bookmark messages when sleeping
+                        trigger -> // ignore scheduled bookmark messages when sleeping
                                 log.debug("Ignoring: <{}>", trigger)
                 )
                 .match(ThingId.class, thingId ->