aboutsummaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/search/dispatch/ReconfigurableDispatcher.java
diff options
context:
space:
mode:
authorJon Marius Venstad <jonmv@users.noreply.github.com>2023-09-05 12:49:39 +0200
committerGitHub <noreply@github.com>2023-09-05 12:49:39 +0200
commit6d783357cf83163a1298372e88020d3d73c25e3c (patch)
tree459daa166d10f7fe743031e707a32c78f839091e /container-search/src/main/java/com/yahoo/search/dispatch/ReconfigurableDispatcher.java
parent2697fbc195ef428210925e4b05223e0ab64405a4 (diff)
parent05df635cab10d2e312a10e0620a0e6558a4de013 (diff)
Merge branch 'master' into renovate/junit5-monorepo
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/dispatch/ReconfigurableDispatcher.java')
-rw-r--r--container-search/src/main/java/com/yahoo/search/dispatch/ReconfigurableDispatcher.java9
1 files changed, 5 insertions, 4 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/ReconfigurableDispatcher.java b/container-search/src/main/java/com/yahoo/search/dispatch/ReconfigurableDispatcher.java
index c86c21d677f..2962fd3a3ec 100644
--- a/container-search/src/main/java/com/yahoo/search/dispatch/ReconfigurableDispatcher.java
+++ b/container-search/src/main/java/com/yahoo/search/dispatch/ReconfigurableDispatcher.java
@@ -1,5 +1,6 @@
package com.yahoo.search.dispatch;
+import ai.vespa.cloud.SystemInfo;
import com.yahoo.component.ComponentId;
import com.yahoo.component.annotation.Inject;
import com.yahoo.config.subscription.ConfigSubscriber;
@@ -20,12 +21,12 @@ public class ReconfigurableDispatcher extends Dispatcher {
private final ConfigSubscriber subscriber;
@Inject
- public ReconfigurableDispatcher(ComponentId clusterId, DispatchConfig dispatchConfig, QrConfig qrConfig, VipStatus vipStatus) {
+ public ReconfigurableDispatcher(ComponentId clusterId, DispatchConfig dispatchConfig, SystemInfo systemInfo, VipStatus vipStatus) {
super(clusterId, dispatchConfig, new DispatchNodesConfig.Builder().build(), vipStatus);
this.subscriber = new ConfigSubscriber();
CountDownLatch configured = new CountDownLatch(1);
this.subscriber.subscribe(config -> { updateWithNewConfig(config); configured.countDown(); },
- DispatchNodesConfig.class, configId(clusterId, qrConfig));
+ DispatchNodesConfig.class, configId(clusterId, systemInfo));
try {
if ( ! configured.await(1, TimeUnit.MINUTES))
throw new IllegalStateException("timed out waiting for initial dispatch nodes config for " + clusterId.getName());
@@ -41,8 +42,8 @@ public class ReconfigurableDispatcher extends Dispatcher {
super.deconstruct();
}
- private static String configId(ComponentId clusterId, QrConfig qrConfig) {
- return qrConfig.clustername() + "/component/" + clusterId.getName();
+ private static String configId(ComponentId clusterId, SystemInfo systemInfo) {
+ return systemInfo.clusterName() + "/component/" + clusterId.getName();
}
}