diff --git a/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/strategies/DirectElasticSearchIndexStrategy.java b/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/strategies/DirectElasticSearchIndexStrategy.java index 3c32c7e2..96ece4c1 100644 --- a/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/strategies/DirectElasticSearchIndexStrategy.java +++ b/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/strategies/DirectElasticSearchIndexStrategy.java @@ -2,14 +2,15 @@ package org.jetlinks.community.elastic.search.index.strategies; import org.jetlinks.community.elastic.search.ElasticRestClient; import org.jetlinks.community.elastic.search.index.ElasticSearchIndexMetadata; +import org.jetlinks.community.elastic.search.index.ElasticSearchIndexProperties; import org.springframework.stereotype.Component; import reactor.core.publisher.Mono; @Component public class DirectElasticSearchIndexStrategy extends AbstractElasticSearchIndexStrategy { - public DirectElasticSearchIndexStrategy(ElasticRestClient client) { - super("direct", client); + public DirectElasticSearchIndexStrategy(ElasticRestClient client, ElasticSearchIndexProperties properties) { + super("direct", client,properties); } @Override diff --git a/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/strategies/TimeByMonthElasticSearchIndexStrategy.java b/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/strategies/TimeByMonthElasticSearchIndexStrategy.java index 544a5820..31ec0789 100644 --- a/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/strategies/TimeByMonthElasticSearchIndexStrategy.java +++ b/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/strategies/TimeByMonthElasticSearchIndexStrategy.java @@ -2,6 +2,7 @@ package org.jetlinks.community.elastic.search.index.strategies; import org.hswebframework.utils.time.DateFormatter; import org.jetlinks.community.elastic.search.ElasticRestClient; +import org.jetlinks.community.elastic.search.index.ElasticSearchIndexProperties; import org.springframework.stereotype.Component; import java.util.Date; @@ -17,8 +18,8 @@ public class TimeByMonthElasticSearchIndexStrategy extends TemplateElasticSearch private final String format = "yyyy-MM"; - public TimeByMonthElasticSearchIndexStrategy(ElasticRestClient client) { - super("time-by-month", client); + public TimeByMonthElasticSearchIndexStrategy(ElasticRestClient client, ElasticSearchIndexProperties properties) { + super("time-by-month", client,properties); } @Override