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.ManagementOverrides
EXPRESSION_PARSER, logger
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
METER_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) |
handleMessage
buildSendTimer, destroy, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrack
afterPropertiesSet, 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, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getThisAs
getBeanName, getComponentName
public R2dbcMessageHandler(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations)
R2dbcEntityOperations
r2dbcEntityOperations
- 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()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class MessageHandlerSupport
protected void onInit()
IntegrationObjectSupport
onInit
in class IntegrationObjectSupport
protected reactor.core.publisher.Mono<Void> handleMessageInternal(Message<?> message)
handleMessageInternal
in class AbstractReactiveMessageHandler