Package org.springframework.integration.mongodb.dsl

Class ReactiveMongoDbMessageHandlerSpec

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<S,H>

org.springframework.integration.dsl.MessageHandlerSpec<S,ReactiveMessageHandlerAdapter>

org.springframework.integration.dsl.ReactiveMessageHandlerSpec<ReactiveMongoDbMessageHandlerSpec,ReactiveMongoDbStoringMessageHandler>

org.springframework.integration.mongodb.dsl.ReactiveMongoDbMessageHandlerSpec

All Implemented Interfaces:

DisposableBean, FactoryBean<ReactiveMessageHandlerAdapter>, InitializingBean, Lifecycle, Phased, SmartLifecycle, ComponentsRegistration

public class ReactiveMongoDbMessageHandlerSpec
extends ReactiveMessageHandlerSpec<ReactiveMongoDbMessageHandlerSpec,ReactiveMongoDbStoringMessageHandler>
implements ComponentsRegistration

A ReactiveMessageHandlerSpec extension for the Reactive MongoDb Outbound endpoint ReactiveMongoDbStoringMessageHandler.

Since:

5.3

Author:

Artem Bilan

Field Summary

Fields inherited from class org.springframework.integration.dsl.ReactiveMessageHandlerSpec

reactiveMessageHandler

Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

logger, PARSER, target

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ReactiveMongoDbMessageHandlerSpec(ReactiveMongoOperations reactiveMongoOperations)
protected	ReactiveMongoDbMessageHandlerSpec(ReactiveMongoDatabaseFactory mongoDbFactory)

Method Summary

Modifier and Type	Method	Description
ReactiveMongoDbMessageHandlerSpec	collectionName(String collectionName)	Configure a collection name to store data.
ReactiveMongoDbMessageHandlerSpec	collectionNameExpression(Expression collectionNameExpression)	Configure a SpEL expression to evaluate a collection name against a request message.
<P> ReactiveMongoDbMessageHandlerSpec	collectionNameFunction(Function<Message<P>,String> collectionNameFunction)	Configure a Function for evaluation a collection against request message.
ReactiveMongoDbMessageHandlerSpec	mongoConverter(MongoConverter mongoConverter)	Configure a MongoConverter.

Methods inherited from class org.springframework.integration.dsl.ReactiveMessageHandlerSpec

getComponentsToRegister

Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

_this, afterPropertiesSet, destroy, doGet, get, getId, getObject, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.integration.dsl.ComponentsRegistration

getComponentsToRegister

Methods inherited from interface org.springframework.beans.factory.FactoryBean

isSingleton

Constructor Details

ReactiveMongoDbMessageHandlerSpec

protected ReactiveMongoDbMessageHandlerSpec(ReactiveMongoDatabaseFactory mongoDbFactory)

ReactiveMongoDbMessageHandlerSpec

protected ReactiveMongoDbMessageHandlerSpec(ReactiveMongoOperations reactiveMongoOperations)

Method Details

mongoConverter

public ReactiveMongoDbMessageHandlerSpec mongoConverter(MongoConverter mongoConverter)

Configure a MongoConverter.

Parameters:

mongoConverter - the MongoConverter to use.

Returns:

the spec

collectionName

public ReactiveMongoDbMessageHandlerSpec collectionName(String collectionName)

Configure a collection name to store data.

Parameters:

collectionName - the explicit collection name to use.

Returns:

the spec

collectionNameFunction

public <P> ReactiveMongoDbMessageHandlerSpec collectionNameFunction(Function<Message<P>,String> collectionNameFunction)

Configure a Function for evaluation a collection against request message.

Type Parameters:

P - an expected payload type

Parameters:

collectionNameFunction - the Function to determine a collection name at runtime.

Returns:

the spec

collectionNameExpression

public ReactiveMongoDbMessageHandlerSpec collectionNameExpression(Expression collectionNameExpression)

Configure a SpEL expression to evaluate a collection name against a request message.

Parameters:

collectionNameExpression - the SpEL expression to use.

Returns:

the spec