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) |
void |
setQueryType(R2dbcMessageHandler.Type type) |
void |
setQueryTypeExpression(org.springframework.expression.Expression queryTypeExpression) |
void |
setTableName(java.lang.String tableName) |
void |
setTableNameExpression(org.springframework.expression.Expression tableNameExpression) |
void |
setValuesExpression(org.springframework.expression.Expression valuesExpression) |
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)
public void setQueryTypeExpression(org.springframework.expression.Expression queryTypeExpression)
public void setTableName(java.lang.String tableName)
public void setTableNameExpression(org.springframework.expression.Expression tableNameExpression)
public void setValuesExpression(org.springframework.expression.Expression valuesExpression)
public void setCriteriaExpression(org.springframework.expression.Expression criteriaExpression)
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