diff options
| -rw-r--r-- | component/src/main/java/com/yahoo/component/AbstractComponent.java | 2 | ||||
| -rw-r--r-- | node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/QuestMetricsDb.java | 6 |
2 files changed, 6 insertions, 2 deletions
diff --git a/component/src/main/java/com/yahoo/component/AbstractComponent.java b/component/src/main/java/com/yahoo/component/AbstractComponent.java index 163a2b0b7ef..fcaa1e62d56 100644 --- a/component/src/main/java/com/yahoo/component/AbstractComponent.java +++ b/component/src/main/java/com/yahoo/component/AbstractComponent.java @@ -20,7 +20,7 @@ public class AbstractComponent implements Component { // We must store the class name, as this.getClass() will yield an exception when a bundled component's // bundle has been uninstalled. - private String className = getClass().getName(); + private final String className = getClass().getName(); protected final boolean isDeconstructable; /** diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/QuestMetricsDb.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/QuestMetricsDb.java index b3632a4e82a..946d47e9246 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/QuestMetricsDb.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/QuestMetricsDb.java @@ -4,6 +4,7 @@ package com.yahoo.vespa.hosted.provision.autoscale; import com.google.inject.Inject; import com.yahoo.collections.ListMap; import com.yahoo.collections.Pair; +import com.yahoo.component.AbstractComponent; import com.yahoo.io.IOUtils; import com.yahoo.vespa.defaults.Defaults; import io.questdb.cairo.CairoConfiguration; @@ -40,7 +41,7 @@ import java.util.stream.Collectors; * * @author bratseth */ -public class QuestMetricsDb implements MetricsDb { +public class QuestMetricsDb extends AbstractComponent implements MetricsDb { private static final Logger log = Logger.getLogger(QuestMetricsDb.class.getName()); private static final String tableName = "metrics"; @@ -143,6 +144,9 @@ public class QuestMetricsDb implements MetricsDb { } @Override + public void deconstruct() { close(); } + + @Override public void close() { if (engine != null) engine.close(); |