public class R2dbcMessageHandler
extends org.springframework.integration.handler.AbstractReactiveMessageHandler
ReactiveMessageHandler which writes
Message payload into a Relational Database, using reactive r2dbc support.| Modifier and Type | Class and Description |
|---|---|
static class |
R2dbcMessageHandler.Type
/**
The mode for the
R2dbcMessageHandler. |
EXPRESSION_PARSER, logger| Constructor and Description |
|---|
R2dbcMessageHandler(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations)
Construct this instance using a fully created and initialized instance of provided
R2dbcEntityOperations |
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
getComponentType() |
protected reactor.core.publisher.Mono<java.lang.Void> |
handleMessageInternal(org.springframework.messaging.Message<?> message) |
protected void |
onInit() |
void |
setCriteriaExpression(org.springframework.expression.Expression criteriaExpression)
Set a SpEL expression to evaluate a
Criteria for query to execute. |
void |
setQueryType(R2dbcMessageHandler.Type type)
Set a
R2dbcMessageHandler.Type for query to execute. |
void |
setQueryTypeExpression(org.springframework.expression.Expression queryTypeExpression)
Set a SpEL expression to evaluate a
R2dbcMessageHandler.Type for query to execute. |
void |
setTableName(java.lang.String tableName)
Specify a table in the target database to execute the query.
|
void |
setTableNameExpression(org.springframework.expression.Expression tableNameExpression)
Set a SpEL expression to evaluate a table name at runtime against request message.
|
void |
setValuesExpression(org.springframework.expression.Expression valuesExpression)
Set a SpEL expression to evaluate a
Map for name-value pairs to bind as parameters
into a query. |
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, waitpublic R2dbcMessageHandler(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations)
R2dbcEntityOperationsr2dbcEntityOperations - The R2dbcEntityOperations implementation.public void setQueryType(R2dbcMessageHandler.Type type)
R2dbcMessageHandler.Type for query to execute.type - the R2dbcMessageHandler.Type to use.public void setQueryTypeExpression(org.springframework.expression.Expression queryTypeExpression)
R2dbcMessageHandler.Type for query to execute.queryTypeExpression - the expression to use.public void setTableName(java.lang.String tableName)
tableName - the name of the table to use.public void setTableNameExpression(org.springframework.expression.Expression tableNameExpression)
tableNameExpression - the expression to use.public void setValuesExpression(org.springframework.expression.Expression valuesExpression)
Map for name-value pairs to bind as parameters
into a query.valuesExpression - the expression to use.public void setCriteriaExpression(org.springframework.expression.Expression criteriaExpression)
Criteria for query to execute.criteriaExpression - the expression to use.public java.lang.String getComponentType()
getComponentType in interface org.springframework.integration.support.context.NamedComponentgetComponentType in class org.springframework.integration.handler.MessageHandlerSupportprotected void onInit()
onInit in class org.springframework.integration.context.IntegrationObjectSupportprotected reactor.core.publisher.Mono<java.lang.Void> handleMessageInternal(org.springframework.messaging.Message<?> message)
handleMessageInternal in class org.springframework.integration.handler.AbstractReactiveMessageHandler