Package org.springframework.cloud.fn.consumer.elasticsearch

Class ElasticsearchConsumerConfiguration

java.lang.Object

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

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

Author:

Soby Chacko, Andrea Montemaggio, Corneil du Plessis

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
ElasticsearchConsumerConfiguration()

Method Summary

Modifier and Type	Method	Description
MessageHandler	indexingHandler(co.elastic.clients.elasticsearch.ElasticsearchClient elasticsearchClient, ElasticsearchConsumerProperties consumerProperties)

Methods inherited from class java.lang.Object

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

Field Details

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 Details

ElasticsearchConsumerConfiguration

public ElasticsearchConsumerConfiguration()

Method Details

indexingHandler

@Bean
public MessageHandler indexingHandler(co.elastic.clients.elasticsearch.ElasticsearchClient elasticsearchClient,
 ElasticsearchConsumerProperties consumerProperties)