Add callback support to RotatingStoreVerticle for keyset key fail-fast feature

- Add Consumer<Boolean> refreshCallback field
- Add constructor overload to accept callback
- Call callback on refresh success/failure
- Maintains backward compatibility with existing constructor

This enables monitoring of store refresh status for fail-fast behavior.

Author: lizk886

src/main/java/com/uid2/shared/vertx/RotatingStoreVerticle.java

@@ -15,6 +15,7 @@
 
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.atomic.AtomicLong;
+import java.util.function.Consumer;
 
 public class RotatingStoreVerticle extends AbstractVerticle {
     private static final Logger LOGGER = LoggerFactory.getLogger(RotatingStoreVerticle.class);
@@ -31,10 +32,16 @@ public class RotatingStoreVerticle extends AbstractVerticle {
     private final AtomicLong latestVersion = new AtomicLong(-1L);
     private final AtomicLong latestEntryCount = new AtomicLong(-1L);
     private final AtomicInteger storeRefreshIsFailing = new AtomicInteger(0);
+    private final Consumer<Boolean> refreshCallback;
 
     private final long refreshIntervalMs;
 
     public RotatingStoreVerticle(String storeName, long refreshIntervalMs, IMetadataVersionedStore versionedStore) {
+        this(storeName, refreshIntervalMs, versionedStore, null);
+    }
+
+    public RotatingStoreVerticle(String storeName, long refreshIntervalMs, IMetadataVersionedStore versionedStore,
+            Consumer<Boolean> refreshCallback) {
         this.healthComponent = HealthManager.instance.registerComponent(storeName + "-rotator");
         this.healthComponent.setHealthStatus(false, "not started");
 
@@ -72,6 +79,7 @@ public RotatingStoreVerticle(String storeName, long refreshIntervalMs, IMetadata
         this.versionedStore = versionedStore;
         this.refreshIntervalMs = refreshIntervalMs;
         this.storeRefreshTimer = Metrics.timer("uid2_store_refresh_duration", "store_name", storeName);
+        this.refreshCallback = refreshCallback;
     }
 
     @Override
@@ -115,15 +123,21 @@ private void startBackgroundRefresh() {
                     final long end = System.nanoTime();
                     final long elapsed = ((end - start) / 1000000);
                     this.counterStoreRefreshTimeMs.increment(elapsed);
-                    if (asyncResult.failed()) {
-                        this.counterStoreRefreshFailures.increment();
-                        this.storeRefreshIsFailing.set(1);
-                        LOGGER.error("Failed to load " + this.storeName + ", " + elapsed + " ms", asyncResult.cause());
-                    } else {
-                        this.counterStoreRefreshed.increment();
-                        this.storeRefreshIsFailing.set(0);
-                        LOGGER.trace("Successfully refreshed " + this.storeName + ", " + elapsed + " ms");
+                if (asyncResult.failed()) {
+                    this.counterStoreRefreshFailures.increment();
+                    this.storeRefreshIsFailing.set(1);
+                    LOGGER.error("Failed to load " + this.storeName + ", " + elapsed + " ms", asyncResult.cause());
+                    if (this.refreshCallback != null) {
+                        this.refreshCallback.accept(false);
                     }
+                } else {
+                    this.counterStoreRefreshed.increment();
+                    this.storeRefreshIsFailing.set(0);
+                    LOGGER.trace("Successfully refreshed " + this.storeName + ", " + elapsed + " ms");
+                    if (this.refreshCallback != null) {
+                        this.refreshCallback.accept(true);
+                    }
+                }
                 }
             );
         });