6161import java .time .Duration ;
6262import java .time .Instant ;
6363import java .util .*;
64- import java .util .function .Consumer ;
6564import java .util .function .Supplier ;
6665
6766import static com .uid2 .operator .Const .Config .EnableRemoteConfigProp ;
@@ -442,8 +441,7 @@ private Future<Void> createStoreVerticles() throws Exception {
442441 }
443442 fs .add (createAndDeployRotatingStoreVerticle ("auth" , clientKeyProvider , "auth_refresh_ms" ));
444443 fs .add (createAndDeployRotatingStoreVerticle ("keyset" , keysetProvider , "keyset_refresh_ms" ));
445- fs .add (createAndDeployRotatingStoreVerticle ("keysetkey" , keysetKeyStore , "keysetkey_refresh_ms" ,
446- this .shutdownHandler ::handleKeysetKeyRefreshResponse ));
444+ fs .add (createAndDeployRotatingStoreVerticle ("keysetkey" , keysetKeyStore , "keysetkey_refresh_ms" ));
447445 fs .add (createAndDeployRotatingStoreVerticle ("salt" , saltProvider , "salt_refresh_ms" ));
448446 fs .add (createAndDeployCloudSyncStoreVerticle ("optout" , fsOptOut , optOutCloudSync ));
449447 CompositeFuture .all (fs ).onComplete (ar -> {
@@ -458,15 +456,9 @@ private Future<Void> createStoreVerticles() throws Exception {
458456
459457 private Future <String > createAndDeployRotatingStoreVerticle (String name , IMetadataVersionedStore store ,
460458 String storeRefreshConfigMs ) {
461- return createAndDeployRotatingStoreVerticle (name , store , storeRefreshConfigMs , null );
462- }
463-
464- private Future <String > createAndDeployRotatingStoreVerticle (String name , IMetadataVersionedStore store ,
465- String storeRefreshConfigMs , Consumer <Boolean > refreshCallback ) {
466459 final int intervalMs = config .getInteger (storeRefreshConfigMs , 10000 );
467460
468- RotatingStoreVerticle rotatingStoreVerticle = new RotatingStoreVerticle (name , intervalMs , store ,
469- refreshCallback );
461+ RotatingStoreVerticle rotatingStoreVerticle = new RotatingStoreVerticle (name , intervalMs , store );
470462 return vertx .deployVerticle (rotatingStoreVerticle );
471463 }
472464
0 commit comments