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
  • Constructor Details

    • R2dbcMessageHandlerSpec

      protected R2dbcMessageHandlerSpec(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations)
  • Method Details

    • queryType

      Set a R2dbcMessageHandler.Type for query to execute.
      Parameters:
      type - the R2dbcMessageHandler.Type to use.
      Returns:
      the spec
    • queryTypeFunction

      public <P> R2dbcMessageHandlerSpec queryTypeFunction(Function<org.springframework.messaging.Message<P>,R2dbcMessageHandler.Type> queryTypeFunction)
      Set a Function to evaluate a R2dbcMessageHandler.Type for query to execute against a request message.
      Type Parameters:
      P - the payload type.
      Parameters:
      queryTypeFunction - the function to use.
      Returns:
      the spec
    • queryTypeExpression

      public R2dbcMessageHandlerSpec queryTypeExpression(String queryTypeExpression)
      Set a SpEL expression to evaluate a R2dbcMessageHandler.Type for 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 a R2dbcMessageHandler.Type for query to execute.
      Parameters:
      queryTypeExpression - the expression to use.
      Returns:
      the spec
    • tableName

      public R2dbcMessageHandlerSpec tableName(String 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(Function<org.springframework.messaging.Message<P>,String> tableNameFunction)
      Set a Function to 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

      public R2dbcMessageHandlerSpec tableNameExpression(String 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(Function<org.springframework.messaging.Message<P>,Map<String,?>> valuesFunction)
      Set a Function to evaluate a Map for 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

      public R2dbcMessageHandlerSpec values(String valuesExpression)
      Set a SpEL expression to evaluate a Map for name-value pairs to bind as parameters into a query.
      Parameters:
      valuesExpression - the expression to use.
      Returns:
      the spec
    • values

      public R2dbcMessageHandlerSpec values(org.springframework.expression.Expression valuesExpression)
      Set a SpEL expression to evaluate a Map for name-value pairs to bind as parameters into a query.
      Parameters:
      valuesExpression - the expression to use.
      Returns:
      the spec
    • criteria

      public <P> R2dbcMessageHandlerSpec criteria(Function<org.springframework.messaging.Message<P>,org.springframework.data.relational.core.query.Criteria> criteriaFunction)
      Set a Function to evaluate a Criteria for query to execute.
      Type Parameters:
      P - the payload type.
      Parameters:
      criteriaFunction - the function to use.
      Returns:
      the spec
    • criteria

      public R2dbcMessageHandlerSpec criteria(String criteriaExpression)
      Set a SpEL expression to evaluate a Criteria for 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 a Criteria for query to execute.
      Parameters:
      criteriaExpression - the expression to use.
      Returns:
      the spec