org.springframework.cloud.fn.consumer.mongo

Class MongoDbConsumerConfiguration

java.lang.Object

org.springframework.cloud.fn.consumer.mongo.MongoDbConsumerConfiguration

@Configuration
 @EnableConfigurationProperties(value=MongoDbConsumerProperties.class)
public class MongoDbConsumerConfiguration
extends Object

A configuration for MongoDB Consumer function. Uses a ReactiveMongoDbStoringMessageHandler to save payload contents to Mongo DB.

Author:

Artem Bilan, David Turanski

Constructor Summary

Constructors

Constructor and Description
MongoDbConsumerConfiguration(MongoDbConsumerProperties properties, org.springframework.data.mongodb.core.ReactiveMongoTemplate mongoTemplate)

Method Summary

Modifier and Type	Method and Description
org.springframework.messaging.ReactiveMessageHandler	mongoConsumerMessageHandler()
Consumer<org.springframework.messaging.Message<?>>	mongodbConsumer(Function<org.springframework.messaging.Message<?>,reactor.core.publisher.Mono<Void>> mongodbConsumerFunction)
Function<org.springframework.messaging.Message<?>,reactor.core.publisher.Mono<Void>>	mongodbConsumerFunction(org.springframework.messaging.ReactiveMessageHandler mongoConsumerMessageHandler)

Methods inherited from class java.lang.Object

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

Constructor Detail

MongoDbConsumerConfiguration

public MongoDbConsumerConfiguration(MongoDbConsumerProperties properties,
                                    org.springframework.data.mongodb.core.ReactiveMongoTemplate mongoTemplate)

Method Detail

mongodbConsumer

@Bean
public Consumer<org.springframework.messaging.Message<?>> mongodbConsumer(Function<org.springframework.messaging.Message<?>,reactor.core.publisher.Mono<Void>> mongodbConsumerFunction)

mongodbConsumerFunction

@Bean
public Function<org.springframework.messaging.Message<?>,reactor.core.publisher.Mono<Void>> mongodbConsumerFunction(org.springframework.messaging.ReactiveMessageHandler mongoConsumerMessageHandler)

mongoConsumerMessageHandler

@Bean
public org.springframework.messaging.ReactiveMessageHandler mongoConsumerMessageHandler()