public class R2dbcMessageHandler extends 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. |
IntegrationManagement.ManagementOverridesEXPRESSION_PARSER, loggerHIGHEST_PRECEDENCE, LOWEST_PRECEDENCEMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME| 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 |
|---|---|
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 |
setCriteriaExpression(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(Expression queryTypeExpression)
Set a SpEL expression to evaluate a
R2dbcMessageHandler.Type for query to execute. |
void |
setTableName(String tableName)
Specify a table in the target database to execute the query.
|
void |
setTableNameExpression(Expression tableNameExpression)
Set a SpEL expression to evaluate a table name at runtime against request message.
|
void |
setValuesExpression(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, waitgetThisAsgetBeanName, getComponentNamepublic 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(Expression queryTypeExpression)
R2dbcMessageHandler.Type for query to execute.queryTypeExpression - the expression to use.public void setTableName(String tableName)
tableName - the name of the table to use.public void setTableNameExpression(Expression tableNameExpression)
tableNameExpression - the expression to use.public void setValuesExpression(Expression valuesExpression)
Map for name-value pairs to bind as parameters
into a query.valuesExpression - the expression to use.public void setCriteriaExpression(Expression criteriaExpression)
Criteria for query to execute.criteriaExpression - the expression to use.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