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

Author:

Soby Chacko, Andrea Montemaggio

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
ElasticsearchConsumerConfiguration()

Method Summary

Modifier and Type	Method and Description
org.springframework.messaging.MessageHandler	indexingHandler(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

INDEX_NAME_HEADER

public static final String INDEX_NAME_HEADER

Message header for the Index name.

See Also:

Constant Field Values

Constructor Detail

ElasticsearchConsumerConfiguration

public ElasticsearchConsumerConfiguration()

Method Detail

indexingHandler

@Bean
public org.springframework.messaging.MessageHandler indexingHandler(org.elasticsearch.client.RestHighLevelClient restHighLevelClient,
                                                                          ElasticsearchConsumerProperties consumerProperties)