public class ReactiveMongoDbMessageHandlerSpec extends org.springframework.integration.dsl.MessageHandlerSpec<ReactiveMongoDbMessageHandlerSpec,org.springframework.integration.handler.ReactiveMessageHandlerAdapter> implements org.springframework.integration.dsl.ComponentsRegistration
MessageHandlerSpec extension for the Reactive MongoDb Outbound endpoint
ReactiveMongoDbStoringMessageHandler.| Modifier and Type | Field and Description |
|---|---|
protected ReactiveMongoDbStoringMessageHandler |
messageHandler |
| Modifier | Constructor and Description |
|---|---|
protected |
ReactiveMongoDbMessageHandlerSpec(org.springframework.data.mongodb.ReactiveMongoDatabaseFactory mongoDbFactory) |
protected |
ReactiveMongoDbMessageHandlerSpec(org.springframework.data.mongodb.core.ReactiveMongoOperations reactiveMongoOperations) |
| Modifier and Type | Method and Description |
|---|---|
ReactiveMongoDbMessageHandlerSpec |
collectionName(java.lang.String collectionName)
Configure a collection name to store data.
|
ReactiveMongoDbMessageHandlerSpec |
collectionNameExpression(org.springframework.expression.Expression collectionNameExpression)
Configure a SpEL expression to evaluate a collection name against a request message.
|
<P> ReactiveMongoDbMessageHandlerSpec |
collectionNameFunction(java.util.function.Function<org.springframework.messaging.Message<P>,java.lang.String> collectionNameFunction)
Configure a
Function for evaluation a collection against request message. |
java.util.Map<java.lang.Object,java.lang.String> |
getComponentsToRegister() |
ReactiveMongoDbMessageHandlerSpec |
mongoConverter(org.springframework.data.mongodb.core.convert.MongoConverter mongoConverter)
Configure a
MongoConverter. |
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stopprotected final ReactiveMongoDbStoringMessageHandler messageHandler
protected ReactiveMongoDbMessageHandlerSpec(org.springframework.data.mongodb.ReactiveMongoDatabaseFactory mongoDbFactory)
protected ReactiveMongoDbMessageHandlerSpec(org.springframework.data.mongodb.core.ReactiveMongoOperations reactiveMongoOperations)
public ReactiveMongoDbMessageHandlerSpec mongoConverter(org.springframework.data.mongodb.core.convert.MongoConverter mongoConverter)
MongoConverter.mongoConverter - the MongoConverter to use.public ReactiveMongoDbMessageHandlerSpec collectionName(java.lang.String collectionName)
collectionName - the explicit collection name to use.public <P> ReactiveMongoDbMessageHandlerSpec collectionNameFunction(java.util.function.Function<org.springframework.messaging.Message<P>,java.lang.String> collectionNameFunction)
Function for evaluation a collection against request message.P - an expected payload typecollectionNameFunction - the Function to determine a collection name at runtime.public ReactiveMongoDbMessageHandlerSpec collectionNameExpression(org.springframework.expression.Expression collectionNameExpression)
collectionNameExpression - the SpEL expression to use.public java.util.Map<java.lang.Object,java.lang.String> getComponentsToRegister()
getComponentsToRegister in interface org.springframework.integration.dsl.ComponentsRegistration