From afe608a0fe17d84a176edbc82a48bf0ed1464ec1 Mon Sep 17 00:00:00 2001 From: Chris Bono Date: Tue, 11 Apr 2023 15:50:59 -0500 Subject: [PATCH] Fix ElasticsearchSink index name header (#446) - Use `Consumer>` on IntegrationFlow rather than `Consumer` Fixes #440 --- .../elasticsearch/ElasticsearchConsumerConfiguration.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/consumer/elasticsearch-consumer/src/main/java/org/springframework/cloud/fn/consumer/elasticsearch/ElasticsearchConsumerConfiguration.java b/consumer/elasticsearch-consumer/src/main/java/org/springframework/cloud/fn/consumer/elasticsearch/ElasticsearchConsumerConfiguration.java index b60ba662..636a22a6 100644 --- a/consumer/elasticsearch-consumer/src/main/java/org/springframework/cloud/fn/consumer/elasticsearch/ElasticsearchConsumerConfiguration.java +++ b/consumer/elasticsearch-consumer/src/main/java/org/springframework/cloud/fn/consumer/elasticsearch/ElasticsearchConsumerConfiguration.java @@ -47,7 +47,6 @@ import org.springframework.integration.aggregator.MessageCountReleaseStrategy; import org.springframework.integration.config.AggregatorFactoryBean; import org.springframework.integration.dsl.IntegrationFlow; import org.springframework.integration.dsl.IntegrationFlowBuilder; -import org.springframework.integration.dsl.IntegrationFlows; import org.springframework.integration.expression.ValueExpression; import org.springframework.integration.store.MessageGroup; import org.springframework.integration.store.MessageGroupStore; @@ -126,7 +125,7 @@ public class ElasticsearchConsumerConfiguration { ) { final IntegrationFlowBuilder builder = - IntegrationFlows.from(Consumer.class, gateway -> gateway.beanName("elasticsearchConsumer")); + IntegrationFlow.from(MessageConsumer.class, gateway -> gateway.beanName("elasticsearchConsumer")); if (properties.getBatchSize() > 1) { builder.handle(aggregator); } @@ -297,4 +296,9 @@ public class ElasticsearchConsumerConfiguration { return message; } } + + private interface MessageConsumer extends Consumer> { + + } + }