org.springframework.cloud.fn.consumer.elasticsearch

Class ElasticsearchConsumerConfiguration

java.lang.Object

org.springframework.cloud.fn.consumer.elasticsearch.ElasticsearchConsumerConfiguration

@Configuration
 @EnableConfigurationProperties(value=ElasticsearchConsumerProperties.class)
public class ElasticsearchConsumerConfiguration
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	INDEX_ID_HEADER Message header for the Index id.

Constructor Summary

Constructors

Constructor and Description
ElasticsearchConsumerConfiguration()

Method Summary

Modifier and Type	Method and Description
Consumer<org.springframework.messaging.Message<?>>	elasticsearchConsumer(org.elasticsearch.client.RestHighLevelClient restHighLevelClient, ElasticsearchConsumerProperties consumerProperties)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

INDEX_ID_HEADER

public static final String INDEX_ID_HEADER

Message header for the Index id.

See Also:

Constant Field Values

Constructor Detail

ElasticsearchConsumerConfiguration

public ElasticsearchConsumerConfiguration()

Method Detail

elasticsearchConsumer

@Bean
public Consumer<org.springframework.messaging.Message<?>> elasticsearchConsumer(org.elasticsearch.client.RestHighLevelClient restHighLevelClient,
                                                                                      ElasticsearchConsumerProperties consumerProperties)