public class ReactiveMongoDbStoringMessageHandler extends AbstractReactiveMessageHandler
ReactiveMessageHandler which writes
Message payload into a MongoDb collection, using reactive MongoDb support, The
collection is identified by evaluation of the collectionNameExpression.IntegrationManagement.ManagementOverridesEXPRESSION_PARSER, loggerHIGHEST_PRECEDENCE, LOWEST_PRECEDENCEMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME| Constructor and Description |
|---|
ReactiveMongoDbStoringMessageHandler(ReactiveMongoDatabaseFactory mongoDbFactory)
Construct this instance using a provided
ReactiveMongoDatabaseFactory |
ReactiveMongoDbStoringMessageHandler(ReactiveMongoOperations mongoTemplate)
Construct this instance using a fully created and initialized instance of provided
ReactiveMongoOperations |
| Modifier and Type | Method and Description |
|---|---|
String |
getComponentType()
Subclasses 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 SpEL
Expression that should resolve to a collection name used by
ReactiveMongoOperations to store data |
void |
setMongoConverter(MongoConverter mongoConverter)
Provide a custom
MongoConverter used to assist in serialization of
data written to MongoDb. |
handleMessagebuildSendTimer, destroy, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrackafterPropertiesSet, 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, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetThisAsgetBeanName, getComponentNamepublic ReactiveMongoDbStoringMessageHandler(ReactiveMongoDatabaseFactory mongoDbFactory)
ReactiveMongoDatabaseFactorymongoDbFactory - The reactive mongoDatabase factory.public ReactiveMongoDbStoringMessageHandler(ReactiveMongoOperations mongoTemplate)
ReactiveMongoOperationsmongoTemplate - The ReactiveMongoOperations implementation.public void setMongoConverter(MongoConverter mongoConverter)
MongoConverter used to assist in serialization of
data written to MongoDb. Only allowed if this instance was constructed with a
ReactiveMongoDatabaseFactory.mongoConverter - The mongo converter.public void setCollectionNameExpression(Expression collectionNameExpression)
Expression that should resolve to a collection name used by
ReactiveMongoOperations to store datacollectionNameExpression - The collection name expression.public String getComponentType()
IntegrationObjectSupportgetComponentType in interface NamedComponentgetComponentType in class MessageHandlerSupportprotected void onInit()
IntegrationObjectSupportonInit in class IntegrationObjectSupportprotected reactor.core.publisher.Mono<Void> handleMessageInternal(Message<?> message)
handleMessageInternal in class AbstractReactiveMessageHandler