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:
Aware
,BeanFactoryAware
,BeanNameAware
,DisposableBean
,InitializingBean
,ApplicationContextAware
,Ordered
,ExpressionCapable
,Orderable
,IntegrationPattern
,NamedComponent
,IntegrationManagement
,TrackableComponent
,ReactiveMessageHandler
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
- Author:
- David Turanski, Artme Bilan
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement
IntegrationManagement.ManagementOverrides
-
Field Summary
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport
EXPRESSION_PARSER, logger
Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
Fields inherited from interface org.springframework.core.Ordered
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
-
Constructor Summary
ConstructorDescriptionReactiveMongoDbStoringMessageHandler
(ReactiveMongoOperations mongoTemplate) Construct this instance using a fully created and initialized instance of providedReactiveMongoOperations
.ReactiveMongoDbStoringMessageHandler
(ReactiveMongoDatabaseFactory mongoDbFactory) Construct this instance using a providedReactiveMongoDatabaseFactory
. -
Method Summary
Modifier and TypeMethodDescriptionSubclasses may implement this method to provide component type information.protected reactor.core.publisher.Mono<Void>
handleMessageInternal
(Message<?> message) protected void
onInit()
Subclasses may implement this for initialization logic.void
setCollectionNameExpression
(Expression collectionNameExpression) Set a SpELExpression
that should resolve to a collection name used byReactiveMongoOperations
to store datavoid
setMongoConverter
(MongoConverter mongoConverter) Provide a customMongoConverter
used to assist in serialization of data written to MongoDb.Methods inherited from class org.springframework.integration.handler.AbstractReactiveMessageHandler
handleMessage
Methods inherited from class org.springframework.integration.handler.MessageHandlerSupport
buildSendTimer, destroy, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getObservationRegistry, getOrder, getOverrides, isLoggingEnabled, isObserved, registerMetricsCaptor, registerObservationRegistry, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrack
Methods 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, toString
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface org.springframework.integration.support.management.IntegrationManagement
getThisAs
Methods inherited from interface org.springframework.integration.support.context.NamedComponent
getBeanName, getComponentName
-
Constructor Details
-
ReactiveMongoDbStoringMessageHandler
Construct this instance using a providedReactiveMongoDatabaseFactory
.- Parameters:
mongoDbFactory
- The reactive mongoDatabase factory.
-
ReactiveMongoDbStoringMessageHandler
Construct this instance using a fully created and initialized instance of providedReactiveMongoOperations
.- Parameters:
mongoTemplate
- The ReactiveMongoOperations implementation.
-
-
Method Details
-
setMongoConverter
Provide a customMongoConverter
used to assist in serialization of data written to MongoDb. Only allowed if this instance was constructed with aReactiveMongoDatabaseFactory
.- Parameters:
mongoConverter
- The mongo converter.
-
setCollectionNameExpression
Set a SpELExpression
that should resolve to a collection name used byReactiveMongoOperations
to store data- Parameters:
collectionNameExpression
- The collection name expression.
-
getComponentType
Description copied from class:IntegrationObjectSupport
Subclasses may implement this method to provide component type information.- Specified by:
getComponentType
in interfaceNamedComponent
- Overrides:
getComponentType
in classMessageHandlerSupport
-
onInit
protected void onInit()Description copied from class:IntegrationObjectSupport
Subclasses may implement this for initialization logic.- Overrides:
onInit
in classIntegrationObjectSupport
-
handleMessageInternal
- Specified by:
handleMessageInternal
in classAbstractReactiveMessageHandler
-