feat: added insert as operationType

pagopa · May 28, 2024 · 4f5c879 · 4f5c879
1 parent 47568fe
commit 4f5c879
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...nboarding-cdc/src/main/java/it/pagopa/selfcare/onboarding/event/OnboardingCdcService.java b/...nboarding-cdc/src/main/java/it/pagopa/selfcare/onboarding/event/OnboardingCdcService.java
@@ -87,7 +87,7 @@ private void initOrderStream() {
         if(Objects.nonNull(resumeToken))
             options = options.resumeAfter(BsonDocument.parse(resumeToken));
 
-        Bson match = Aggregates.match(Filters.in("operationType", asList("update", "replace")));
+        Bson match = Aggregates.match(Filters.in("operationType", asList("update", "replace", "insert")));
         Bson project = Aggregates.project(fields(include("_id", "ns", "documentKey", "fullDocument")));
         List<Bson> pipeline = Arrays.asList(match, project);