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

    Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

    PARSER, target

    Fields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

    logger

    Fields inherited from interface org.springframework.beans.factory.FactoryBean

    OBJECT_TYPE_ATTRIBUTE

    Fields inherited from interface org.springframework.context.SmartLifecycle

    DEFAULT_PHASE
  • Constructor Summary

    Constructors 
    Modifier Constructor Description
    protected R2dbcMessageHandlerSpec​(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations)  
  • Method Summary

    Modifier and Type Method Description
    R2dbcMessageHandlerSpec criteria​(java.lang.String criteriaExpression)
    Set a SpEL expression to evaluate a Criteria for query to execute.
    <P> R2dbcMessageHandlerSpec criteria​(java.util.function.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.
    R2dbcMessageHandlerSpec criteria​(org.springframework.expression.Expression criteriaExpression)
    Set a SpEL expression to evaluate a Criteria for query to execute.
    R2dbcMessageHandlerSpec queryType​(R2dbcMessageHandler.Type type)
    Set a R2dbcMessageHandler.Type for query to execute.
    R2dbcMessageHandlerSpec queryTypeExpression​(java.lang.String queryTypeExpression)
    Set a SpEL expression to evaluate a R2dbcMessageHandler.Type for query to execute.
    R2dbcMessageHandlerSpec queryTypeExpression​(org.springframework.expression.Expression queryTypeExpression)
    Set a SpEL expression to evaluate a R2dbcMessageHandler.Type for query to execute.
    <P> R2dbcMessageHandlerSpec queryTypeFunction​(java.util.function.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.
    R2dbcMessageHandlerSpec tableName​(java.lang.String tableName)
    Specify a table in the target database to execute the query.
    R2dbcMessageHandlerSpec tableNameExpression​(java.lang.String tableNameExpression)
    Set a SpEL expression to evaluate a table name at runtime against request message.
    R2dbcMessageHandlerSpec tableNameExpression​(org.springframework.expression.Expression tableNameExpression)
    Set a SpEL expression to evaluate a table name at runtime against request message.
    <P> R2dbcMessageHandlerSpec tableNameFunction​(java.util.function.Function<org.springframework.messaging.Message<P>,​java.lang.String> tableNameFunction)
    Set a Function to evaluate a table name at runtime against request message.
    R2dbcMessageHandlerSpec values​(java.lang.String valuesExpression)
    Set a SpEL expression to evaluate a Map for name-value pairs to bind as parameters into a query.
    <P> R2dbcMessageHandlerSpec values​(java.util.function.Function<org.springframework.messaging.Message<P>,​java.util.Map<java.lang.String,​?>> valuesFunction)
    Set a Function to evaluate a Map for name-value pairs to bind as parameters into a query.
    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.

    Methods inherited from class org.springframework.integration.dsl.ReactiveMessageHandlerSpec

    getComponentsToRegister

    Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

    _this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop

    Methods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

    afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • 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​(java.util.function.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​(java.lang.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​(java.lang.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​(java.util.function.Function<org.springframework.messaging.Message<P>,​java.lang.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​(java.lang.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​(java.util.function.Function<org.springframework.messaging.Message<P>,​java.util.Map<java.lang.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​(java.lang.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​(java.util.function.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​(java.lang.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