diff --git a/oap-server/analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace/parser/ISegmentParserListenerManager.java b/oap-server/analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace/parser/ISegmentParserListenerManager.java index e6aaed4914b6b1602d7a133150835146d085b50e..8d3f41b1148c118ab60f894b3fd75ad775fcec75 100644 --- a/oap-server/analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace/parser/ISegmentParserListenerManager.java +++ b/oap-server/analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace/parser/ISegmentParserListenerManager.java @@ -20,6 +20,10 @@ package org.apache.skywalking.oap.server.analyzer.provider.trace.parser; import org.apache.skywalking.oap.server.analyzer.provider.trace.parser.listener.AnalysisListenerFactory; +import java.util.List; + public interface ISegmentParserListenerManager { void add(AnalysisListenerFactory analysisListenerFactory); + + List getSpanListenerFactories(); } diff --git a/oap-server/analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace/parser/SegmentParserListenerManager.java b/oap-server/analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace/parser/SegmentParserListenerManager.java index ef1f07a76218b0406ac93f5180da82234d5b7a22..6663e70a5b8b2e59eb0bbe6d4e3375e450821b25 100644 --- a/oap-server/analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace/parser/SegmentParserListenerManager.java +++ b/oap-server/analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace/parser/SegmentParserListenerManager.java @@ -36,7 +36,8 @@ public class SegmentParserListenerManager implements ISegmentParserListenerManag spanListenerFactories.add(analysisListenerFactory); } - List getSpanListenerFactories() { + @Override + public List getSpanListenerFactories() { return spanListenerFactories; } } diff --git a/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/base/MetricsEsDAO.java b/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/base/MetricsEsDAO.java index 7ff7960f10e8ebcba148a7680c2103edd7701f5e..5d1290f7eccc7f18728b4ab45b55ffcfbf49588d 100644 --- a/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/base/MetricsEsDAO.java +++ b/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/base/MetricsEsDAO.java @@ -44,7 +44,7 @@ import org.joda.time.DateTime; public class MetricsEsDAO extends EsDAO implements IMetricsDAO { protected final StorageBuilder storageBuilder; - protected MetricsEsDAO(ElasticSearchClient client, + public MetricsEsDAO(ElasticSearchClient client, StorageBuilder storageBuilder) { super(client); this.storageBuilder = storageBuilder;