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) |
void |
setQueryType(R2dbcMessageHandler.Type type) |
void |
setQueryTypeExpression(Expression queryTypeExpression) |
void |
setTableName(String tableName) |
void |
setTableNameExpression(Expression tableNameExpression) |
void |
setValuesExpression(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, waitgetThisAsgetBeanName, getComponentNamepublic R2dbcMessageHandler(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations)
R2dbcEntityOperationsr2dbcEntityOperations - The R2dbcEntityOperations implementation.public void setQueryType(R2dbcMessageHandler.Type type)
public void setQueryTypeExpression(Expression queryTypeExpression)
public void setTableName(String tableName)
public void setTableNameExpression(Expression tableNameExpression)
public void setValuesExpression(Expression valuesExpression)
public void setCriteriaExpression(Expression criteriaExpression)
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