Class ReactiveMongoDbStoringMessageHandler
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractReactiveMessageHandler
org.springframework.integration.mongodb.outbound.ReactiveMongoDbStoringMessageHandler
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.context.ApplicationContextAware,org.springframework.core.Ordered,org.springframework.integration.context.ExpressionCapable,org.springframework.integration.context.Orderable,org.springframework.integration.IntegrationPattern,org.springframework.integration.support.context.NamedComponent,org.springframework.integration.support.management.IntegrationManagement,org.springframework.integration.support.management.TrackableComponent,org.springframework.messaging.ReactiveMessageHandler
public class ReactiveMongoDbStoringMessageHandler
extends org.springframework.integration.handler.AbstractReactiveMessageHandler
Implementation of
ReactiveMessageHandler which writes
Message payload into a MongoDb collection, using reactive MongoDb support, The
collection is identified by evaluation of the collectionNameExpression.- Since:
- 5.3
-
Nested Class Summary
-
Field Summary
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport
EXPRESSION_PARSER, logger -
Constructor Summary
Constructors Constructor Description ReactiveMongoDbStoringMessageHandler(org.springframework.data.mongodb.core.ReactiveMongoOperations mongoTemplate)Construct this instance using a fully created and initialized instance of providedReactiveMongoOperationsReactiveMongoDbStoringMessageHandler(org.springframework.data.mongodb.ReactiveMongoDatabaseFactory mongoDbFactory)Construct this instance using a providedReactiveMongoDatabaseFactory -
Method Summary
Modifier and Type Method Description java.lang.StringgetComponentType()protected reactor.core.publisher.Mono<java.lang.Void>handleMessageInternal(org.springframework.messaging.Message<?> message)protected voidonInit()voidsetCollectionNameExpression(org.springframework.expression.Expression collectionNameExpression)Set a SpELExpressionthat should resolve to a collection name used byReactiveMongoOperationsto store datavoidsetMongoConverter(org.springframework.data.mongodb.core.convert.MongoConverter mongoConverter)Provide a customMongoConverterused to assist in serialization of data written to MongoDb.Methods inherited from class org.springframework.integration.handler.AbstractReactiveMessageHandler
handleMessageMethods inherited from class org.springframework.integration.handler.MessageHandlerSupport
buildSendTimer, destroy, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrackMethods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Constructor Details
-
ReactiveMongoDbStoringMessageHandler
public ReactiveMongoDbStoringMessageHandler(org.springframework.data.mongodb.ReactiveMongoDatabaseFactory mongoDbFactory)Construct this instance using a providedReactiveMongoDatabaseFactory- Parameters:
mongoDbFactory- The reactive mongoDatabase factory.
-
ReactiveMongoDbStoringMessageHandler
public ReactiveMongoDbStoringMessageHandler(org.springframework.data.mongodb.core.ReactiveMongoOperations mongoTemplate)Construct this instance using a fully created and initialized instance of providedReactiveMongoOperations- Parameters:
mongoTemplate- The ReactiveMongoOperations implementation.
-
-
Method Details
-
setMongoConverter
public void setMongoConverter(org.springframework.data.mongodb.core.convert.MongoConverter mongoConverter)Provide a customMongoConverterused to assist in serialization of data written to MongoDb. Only allowed if this instance was constructed with aReactiveMongoDatabaseFactory.- Parameters:
mongoConverter- The mongo converter.
-
setCollectionNameExpression
public void setCollectionNameExpression(org.springframework.expression.Expression collectionNameExpression)Set a SpELExpressionthat should resolve to a collection name used byReactiveMongoOperationsto store data- Parameters:
collectionNameExpression- The collection name expression.
-
getComponentType
public java.lang.String getComponentType()- Specified by:
getComponentTypein interfaceorg.springframework.integration.support.context.NamedComponent- Overrides:
getComponentTypein classorg.springframework.integration.handler.MessageHandlerSupport
-
onInit
protected void onInit()- Overrides:
onInitin classorg.springframework.integration.context.IntegrationObjectSupport
-
handleMessageInternal
protected reactor.core.publisher.Mono<java.lang.Void> handleMessageInternal(org.springframework.messaging.Message<?> message)- Specified by:
handleMessageInternalin classorg.springframework.integration.handler.AbstractReactiveMessageHandler
-