diff options
author | Harald Musum <musum@verizonmedia.com> | 2021-02-10 10:31:15 +0100 |
---|---|---|
committer | Harald Musum <musum@verizonmedia.com> | 2021-02-10 10:31:15 +0100 |
commit | 0529c5b92d362b8307c400d9e6f610e5e1b9e8d7 (patch) | |
tree | 024721e0c0dd95a8ca2545489dc73264f67ebacf /configserver | |
parent | da5fe192cfda31bc1d3c6866500c3dfdd09afce2 (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.java | 16 |
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); } /** |