bug fix

Ian-Nara · Ian-Nara · commit 75cb5b42ae53 · 2026-01-20T22:20:53.000-07:00
diff --git a/src/main/java/com/uid2/shared/optout/OptOutCloudSync.java b/src/main/java/com/uid2/shared/optout/OptOutCloudSync.java
@@ -198,8 +198,8 @@ public boolean refresh(Instant now, ICloudStorage fsCloud, ICloudStorage fsLocal
                     if (deltasToMerge.size() == 0) {
                         LOGGER.warn("Skip partition produce due to no delta files found between now and last partition");
                     } else {
-                        LOGGER.debug("sending " + this.eventMergeDelta);
-                        vertx.eventBus().send(this.eventMergeDelta, Utils.toJson(deltasToMerge));
+                        LOGGER.info("publishing partition.produce event with {} delta files", deltasToMerge.size());
+                        vertx.eventBus().publish(this.eventMergeDelta, Utils.toJson(deltasToMerge));
                     }
                 }
             } else if (this.handlerIndexUpdate != null) {

Original file line number	Diff line number	Diff line change
`@@ -198,8 +198,8 @@ public boolean refresh(Instant now, ICloudStorage fsCloud, ICloudStorage fsLocal`
`198`	`198`	`if (deltasToMerge.size() == 0) {`
`199`	`199`	`LOGGER.warn("Skip partition produce due to no delta files found between now and last partition");`
`200`	`200`	`} else {`
`201`		`- LOGGER.debug("sending " + this.eventMergeDelta);`
`202`		`- vertx.eventBus().send(this.eventMergeDelta, Utils.toJson(deltasToMerge));`
	`201`	`+ LOGGER.info("publishing partition.produce event with {} delta files", deltasToMerge.size());`
	`202`	`+ vertx.eventBus().publish(this.eventMergeDelta, Utils.toJson(deltasToMerge));`
`203`	`203`	`}`
`204`	`204`	`}`
`205`	`205`	`} else if (this.handlerIndexUpdate != null) {`