Class R2dbcMessageHandler
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractReactiveMessageHandler
org.springframework.integration.r2dbc.outbound.R2dbcMessageHandler
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.context.ApplicationContextAware,org.springframework.core.Ordered,org.springframework.integration.context.ExpressionCapable,org.springframework.integration.context.Orderable,org.springframework.integration.IntegrationPattern,org.springframework.integration.support.context.NamedComponent,org.springframework.integration.support.management.IntegrationManagement,org.springframework.integration.support.management.TrackableComponent,org.springframework.messaging.ReactiveMessageHandler
public class R2dbcMessageHandler
extends org.springframework.integration.handler.AbstractReactiveMessageHandler
Implementation of
ReactiveMessageHandler which writes
Message payload into a Relational Database, using reactive r2dbc support.- Since:
- 5.4
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classR2dbcMessageHandler.Type/** The mode for theR2dbcMessageHandler. -
Field Summary
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport
EXPRESSION_PARSER, logger -
Constructor Summary
Constructors Constructor Description R2dbcMessageHandler(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations)Construct this instance using a fully created and initialized instance of providedR2dbcEntityOperations -
Method Summary
Modifier and Type Method Description java.lang.StringgetComponentType()protected reactor.core.publisher.Mono<java.lang.Void>handleMessageInternal(org.springframework.messaging.Message<?> message)protected voidonInit()voidsetCriteriaExpression(org.springframework.expression.Expression criteriaExpression)Set a SpEL expression to evaluate aCriteriafor query to execute.voidsetQueryType(R2dbcMessageHandler.Type type)Set aR2dbcMessageHandler.Typefor query to execute.voidsetQueryTypeExpression(org.springframework.expression.Expression queryTypeExpression)Set a SpEL expression to evaluate aR2dbcMessageHandler.Typefor query to execute.voidsetTableName(java.lang.String tableName)Specify a table in the target database to execute the query.voidsetTableNameExpression(org.springframework.expression.Expression tableNameExpression)Set a SpEL expression to evaluate a table name at runtime against request message.voidsetValuesExpression(org.springframework.expression.Expression valuesExpression)Set a SpEL expression to evaluate aMapfor name-value pairs to bind as parameters into a query.Methods inherited from class org.springframework.integration.handler.AbstractReactiveMessageHandler
handleMessageMethods inherited from class org.springframework.integration.handler.MessageHandlerSupport
buildSendTimer, destroy, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrackMethods inherited from class org.springframework.integration.context.IntegrationObjectSupport
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, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Constructor Details
-
R2dbcMessageHandler
public R2dbcMessageHandler(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations)Construct this instance using a fully created and initialized instance of providedR2dbcEntityOperations- Parameters:
r2dbcEntityOperations- The R2dbcEntityOperations implementation.
-
-
Method Details
-
setQueryType
Set aR2dbcMessageHandler.Typefor query to execute.- Parameters:
type- theR2dbcMessageHandler.Typeto use.
-
setQueryTypeExpression
public void setQueryTypeExpression(org.springframework.expression.Expression queryTypeExpression)Set a SpEL expression to evaluate aR2dbcMessageHandler.Typefor query to execute.- Parameters:
queryTypeExpression- the expression to use.
-
setTableName
public void setTableName(java.lang.String tableName)Specify a table in the target database to execute the query.- Parameters:
tableName- the name of the table to use.
-
setTableNameExpression
public void setTableNameExpression(org.springframework.expression.Expression tableNameExpression)Set a SpEL expression to evaluate a table name at runtime against request message.- Parameters:
tableNameExpression- the expression to use.
-
setValuesExpression
public void setValuesExpression(org.springframework.expression.Expression valuesExpression)Set a SpEL expression to evaluate aMapfor name-value pairs to bind as parameters into a query.- Parameters:
valuesExpression- the expression to use.
-
setCriteriaExpression
public void setCriteriaExpression(org.springframework.expression.Expression criteriaExpression)Set a SpEL expression to evaluate aCriteriafor query to execute.- Parameters:
criteriaExpression- the expression to use.
-
getComponentType
public java.lang.String getComponentType()- Specified by:
getComponentTypein interfaceorg.springframework.integration.support.context.NamedComponent- Overrides:
getComponentTypein classorg.springframework.integration.handler.MessageHandlerSupport
-
onInit
protected void onInit()- Overrides:
onInitin classorg.springframework.integration.context.IntegrationObjectSupport
-
handleMessageInternal
protected reactor.core.publisher.Mono<java.lang.Void> handleMessageInternal(org.springframework.messaging.Message<?> message)- Specified by:
handleMessageInternalin classorg.springframework.integration.handler.AbstractReactiveMessageHandler
-