Class R2dbcMessageHandlerSpec
java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,H>
org.springframework.integration.dsl.MessageHandlerSpec<S,org.springframework.integration.handler.ReactiveMessageHandlerAdapter>
org.springframework.integration.dsl.ReactiveMessageHandlerSpec<R2dbcMessageHandlerSpec,R2dbcMessageHandler>
org.springframework.integration.r2dbc.dsl.R2dbcMessageHandlerSpec
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanClassLoaderAware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.FactoryBean<org.springframework.integration.handler.ReactiveMessageHandlerAdapter>,org.springframework.beans.factory.InitializingBean,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle,org.springframework.integration.dsl.ComponentsRegistration
public class R2dbcMessageHandlerSpec extends org.springframework.integration.dsl.ReactiveMessageHandlerSpec<R2dbcMessageHandlerSpec,R2dbcMessageHandler>
The
ReactiveMessageHandlerSpec for the R2dbcMessageHandler.- Since:
- 5.4
-
Field Summary
Fields inherited from class org.springframework.integration.dsl.ReactiveMessageHandlerSpec
reactiveMessageHandler -
Constructor Summary
Constructors Modifier Constructor Description protectedR2dbcMessageHandlerSpec(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations) -
Method Summary
Modifier and Type Method Description R2dbcMessageHandlerSpeccriteria(java.lang.String criteriaExpression)Set a SpEL expression to evaluate aCriteriafor query to execute.<P> R2dbcMessageHandlerSpeccriteria(java.util.function.Function<org.springframework.messaging.Message<P>,org.springframework.data.relational.core.query.Criteria> criteriaFunction)Set aFunctionto evaluate aCriteriafor query to execute.R2dbcMessageHandlerSpeccriteria(org.springframework.expression.Expression criteriaExpression)Set a SpEL expression to evaluate aCriteriafor query to execute.R2dbcMessageHandlerSpecqueryType(R2dbcMessageHandler.Type type)Set aR2dbcMessageHandler.Typefor query to execute.R2dbcMessageHandlerSpecqueryTypeExpression(java.lang.String queryTypeExpression)Set a SpEL expression to evaluate aR2dbcMessageHandler.Typefor query to execute.R2dbcMessageHandlerSpecqueryTypeExpression(org.springframework.expression.Expression queryTypeExpression)Set a SpEL expression to evaluate aR2dbcMessageHandler.Typefor query to execute.<P> R2dbcMessageHandlerSpecqueryTypeFunction(java.util.function.Function<org.springframework.messaging.Message<P>,R2dbcMessageHandler.Type> queryTypeFunction)Set aFunctionto evaluate aR2dbcMessageHandler.Typefor query to execute against a request message.R2dbcMessageHandlerSpectableName(java.lang.String tableName)Specify a table in the target database to execute the query.R2dbcMessageHandlerSpectableNameExpression(java.lang.String tableNameExpression)Set a SpEL expression to evaluate a table name at runtime against request message.R2dbcMessageHandlerSpectableNameExpression(org.springframework.expression.Expression tableNameExpression)Set a SpEL expression to evaluate a table name at runtime against request message.<P> R2dbcMessageHandlerSpectableNameFunction(java.util.function.Function<org.springframework.messaging.Message<P>,java.lang.String> tableNameFunction)Set aFunctionto evaluate a table name at runtime against request message.R2dbcMessageHandlerSpecvalues(java.lang.String valuesExpression)Set a SpEL expression to evaluate aMapfor name-value pairs to bind as parameters into a query.<P> R2dbcMessageHandlerSpecvalues(java.util.function.Function<org.springframework.messaging.Message<P>,java.util.Map<java.lang.String,?>> valuesFunction)Set aFunctionto evaluate aMapfor name-value pairs to bind as parameters into a query.R2dbcMessageHandlerSpecvalues(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.dsl.ReactiveMessageHandlerSpec
getComponentsToRegisterMethods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop
-
Constructor Details
-
R2dbcMessageHandlerSpec
protected R2dbcMessageHandlerSpec(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations)
-
-
Method Details
-
queryType
Set aR2dbcMessageHandler.Typefor query to execute.- Parameters:
type- theR2dbcMessageHandler.Typeto use.- Returns:
- the spec
-
queryTypeFunction
public <P> R2dbcMessageHandlerSpec queryTypeFunction(java.util.function.Function<org.springframework.messaging.Message<P>,R2dbcMessageHandler.Type> queryTypeFunction)Set aFunctionto evaluate aR2dbcMessageHandler.Typefor query to execute against a request message.- Type Parameters:
P- the payload type.- Parameters:
queryTypeFunction- the function to use.- Returns:
- the spec
-
queryTypeExpression
Set a SpEL expression to evaluate aR2dbcMessageHandler.Typefor query to execute.- Parameters:
queryTypeExpression- the expression to use.- Returns:
- the spec
-
queryTypeExpression
public R2dbcMessageHandlerSpec queryTypeExpression(org.springframework.expression.Expression queryTypeExpression)Set a SpEL expression to evaluate aR2dbcMessageHandler.Typefor query to execute.- Parameters:
queryTypeExpression- the expression to use.- Returns:
- the spec
-
tableName
Specify a table in the target database to execute the query.- Parameters:
tableName- the name of the table to use.- Returns:
- the spec
-
tableNameFunction
public <P> R2dbcMessageHandlerSpec tableNameFunction(java.util.function.Function<org.springframework.messaging.Message<P>,java.lang.String> tableNameFunction)Set aFunctionto evaluate a table name at runtime against request message.- Type Parameters:
P- the payload type.- Parameters:
tableNameFunction- the function to use.- Returns:
- the spec
-
tableNameExpression
Set a SpEL expression to evaluate a table name at runtime against request message.- Parameters:
tableNameExpression- the expression to use.- Returns:
- the spec
-
tableNameExpression
public R2dbcMessageHandlerSpec tableNameExpression(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.- Returns:
- the spec
-
values
public <P> R2dbcMessageHandlerSpec values(java.util.function.Function<org.springframework.messaging.Message<P>,java.util.Map<java.lang.String,?>> valuesFunction)Set aFunctionto evaluate aMapfor name-value pairs to bind as parameters into a query.- Type Parameters:
P- the payload type.- Parameters:
valuesFunction- the function to use.- Returns:
- the spec
-
values
Set a SpEL expression to evaluate aMapfor name-value pairs to bind as parameters into a query.- Parameters:
valuesExpression- the expression to use.- Returns:
- the spec
-
values
Set a SpEL expression to evaluate aMapfor name-value pairs to bind as parameters into a query.- Parameters:
valuesExpression- the expression to use.- Returns:
- the spec
-
criteria
public <P> R2dbcMessageHandlerSpec criteria(java.util.function.Function<org.springframework.messaging.Message<P>,org.springframework.data.relational.core.query.Criteria> criteriaFunction)Set aFunctionto evaluate aCriteriafor query to execute.- Type Parameters:
P- the payload type.- Parameters:
criteriaFunction- the function to use.- Returns:
- the spec
-
criteria
Set a SpEL expression to evaluate aCriteriafor query to execute.- Parameters:
criteriaExpression- the expression to use.- Returns:
- the spec
-
criteria
public R2dbcMessageHandlerSpec criteria(org.springframework.expression.Expression criteriaExpression)Set a SpEL expression to evaluate aCriteriafor query to execute.- Parameters:
criteriaExpression- the expression to use.- Returns:
- the spec
-