fixed that for empty BulkUpdate no "BulkWriteComplete" was sent back …

…to ThingUpdaters Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
eclipse-ditto · Mar 9, 2022 · 5a9f314 · 5a9f314
1 parent 6ebbe7e
commit 5a9f314
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/...eclipse/ditto/thingsearch/service/persistence/write/streaming/MongoSearchUpdaterFlow.java b/...eclipse/ditto/thingsearch/service/persistence/write/streaming/MongoSearchUpdaterFlow.java
@@ -135,15 +135,18 @@ private Source<WriteResultAndErrors, NotUsed> executeBulkWrite(final boolean sho
         final var abstractWriteModels = pairs.stream().map(Pair::first).toList();
         final var writeModels = pairs.stream().map(Pair::second).toList();
 
+        final String bulkWriteCorrelationId = UUID.randomUUID().toString();
         if (writeModels.isEmpty()) {
-            LOGGER.debug("Requested to make empty update by write models <{}>", abstractWriteModels);
+            LOGGER.withCorrelationId(bulkWriteCorrelationId)
+                    .debug("Requested to make empty update by write models <{}>", abstractWriteModels);
             for (final var abstractWriteModel : abstractWriteModels) {
                 abstractWriteModel.getMetadata().sendWeakAck(null);
+                abstractWriteModel.getMetadata().getOrigin().ifPresent(origin ->
+                        origin.tell(BulkWriteComplete.of(bulkWriteCorrelationId), ActorRef.noSender()));
             }
             return Source.empty();
         }
 
-        final String bulkWriteCorrelationId = UUID.randomUUID().toString();
         if (LOGGER.isDebugEnabled()) {
             LOGGER.withCorrelationId(bulkWriteCorrelationId)
                     .debug("Executing BulkWrite containing [<thingId>:{correlationIds}:<filter>]: {}", pairs.stream()