summaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorHarald Musum <musum@verizonmedia.com>2021-02-10 10:31:15 +0100
committerHarald Musum <musum@verizonmedia.com>2021-02-10 10:31:15 +0100
commit0529c5b92d362b8307c400d9e6f610e5e1b9e8d7 (patch)
tree024721e0c0dd95a8ca2545489dc73264f67ebacf /configserver
parentda5fe192cfda31bc1d3c6866500c3dfdd09afce2 (diff)
There is just one tenant listener, remove list
Diffstat (limited to 'configserver')
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java16
1 files changed, 4 insertions, 12 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java b/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java
index 2263cafe2d1..fedcd7a1233 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java
@@ -95,7 +95,7 @@ public class TenantRepository {
private final Map<TenantName, Tenant> tenants = Collections.synchronizedMap(new LinkedHashMap<>());
private final Locks<TenantName> tenantLocks = new Locks<>(1, TimeUnit.MINUTES);
private final HostRegistry hostRegistry;
- private final List<TenantListener> tenantListeners = Collections.synchronizedList(new ArrayList<>());
+ private final TenantListener tenantListener;
private final Curator curator;
private final Metrics metrics;
private final MetricUpdater metricUpdater;
@@ -112,7 +112,6 @@ public class TenantRepository {
private final ModelFactoryRegistry modelFactoryRegistry;
private final ConfigDefinitionRepo configDefinitionRepo;
private final ReloadListener reloadListener;
- private final TenantListener tenantListener;
private final ExecutorService bootstrapExecutor;
private final ScheduledExecutorService checkForRemovedApplicationsService =
new ScheduledThreadPoolExecutor(1, new DaemonThreadFactory("check for removed applications"));
@@ -179,7 +178,6 @@ public class TenantRepository {
this.curator = curator;
this.metrics = metrics;
metricUpdater = metrics.getOrCreateMetricUpdater(Collections.emptyMap());
- this.tenantListeners.add(tenantListener);
this.zkCacheExecutor = zkCacheExecutor;
this.zkWatcherExecutor = zkWatcherExecutor;
this.fileDistributionFactory = fileDistributionFactory;
@@ -213,9 +211,7 @@ public class TenantRepository {
}
private void notifyTenantsLoaded() {
- for (TenantListener tenantListener : tenantListeners) {
- tenantListener.onTenantsLoaded();
- }
+ tenantListener.onTenantsLoaded();
}
public Tenant addTenant(TenantName tenantName) {
@@ -376,15 +372,11 @@ public class TenantRepository {
}
private void notifyNewTenant(Tenant tenant) {
- for (TenantListener listener : tenantListeners) {
- listener.onTenantCreate(tenant);
- }
+ tenantListener.onTenantCreate(tenant);
}
private void notifyRemovedTenant(TenantName name) {
- for (TenantListener listener : tenantListeners) {
- listener.onTenantDelete(name);
- }
+ tenantListener.onTenantDelete(name);
}
/**