パッケージ org.springframework.integration.cassandra.dsl

クラス CassandraMessageHandlerSpec

java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec<S,H>
org.springframework.integration.dsl.MessageHandlerSpec<CassandraMessageHandlerSpec,CassandraMessageHandler>
org.springframework.integration.cassandra.dsl.CassandraMessageHandlerSpec
実装済みのインターフェース一覧:
DisposableBean、FactoryBean<CassandraMessageHandler>、InitializingBean、Lifecycle、Phased、SmartLifecycle
public class CassandraMessageHandlerSpec extends MessageHandlerSpec<CassandraMessageHandlerSpec,CassandraMessageHandler>
CassandraMessageHandler の MessageHandlerSpec。
導入:
6.0
作成者:
Artem Bilan

  • コンストラクターの詳細

    • CassandraMessageHandlerSpec

      protected CassandraMessageHandlerSpec(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations)

    • CassandraMessageHandlerSpec

      protected CassandraMessageHandlerSpec(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations, CassandraMessageHandler.Type queryType)

  • 方法の詳細

    • producesReply

      protected CassandraMessageHandlerSpec producesReply(boolean producesReply)

    • ingestQuery

      public CassandraMessageHandlerSpec ingestQuery(StringSE ingestQuery)
      取り込みクエリを設定します。
      パラメーター:
      ingestQuery - 使用する取り込みクエリ。
      戻り値:
      このスペック

    • writeOptions

      public CassandraMessageHandlerSpec writeOptions(org.springframework.data.cassandra.core.cql.WriteOptions writeOptions)
      INSERT、UPDATE または DELETE 操作に対して WriteOptions を設定します。
      パラメーター:
      writeOptions - 使用する WriteOptions。
      戻り値:
      このスペック

    • statementExpression

      public CassandraMessageHandlerSpec statementExpression(StringSE statementExpression)
      リクエストメッセージに対して Statement を評価する SpEL 式を設定します。
      パラメーター:
      statementExpression - 使用する SpEL 式。
      戻り値:
      このスペック

    • statementExpression

      public CassandraMessageHandlerSpec statementExpression(Expression statementExpression)
      リクエストメッセージに対して Statement を評価する SpEL 式を設定します。
      パラメーター:
      statementExpression - 使用する SpEL 式。
      戻り値:
      このスペック

    • statementFunction

      public CassandraMessageHandlerSpec statementFunction(FunctionSE<Message<?>,com.datastax.oss.driver.api.core.cql.Statement<?>> statementFunction)
      FunctionSE を設定して、リクエストメッセージに対して Statement を評価します。
      パラメーター:
      statementFunction - 使用する関数。
      戻り値:
      このスペック

    • query

      public CassandraMessageHandlerSpec query(StringSE query)
      SELECT クエリを設定します。
      パラメーター:
      query - 実行する CQL クエリ
      戻り値:
      このスペック

    • parameterExpressions

      public CassandraMessageHandlerSpec parameterExpressions(MapSE<StringSE,Expression> parameterExpressions)
      リクエストメッセージに対して、名前付きパラメーターとその値の式のマップを設定します。
      パラメーター:
      parameterExpressions - 使用するマップ。
      戻り値:
      このスペック

    • parameter

      public CassandraMessageHandlerSpec parameter(StringSE name, StringSE expression)
      名前付きバインド可能パラメーターを SpEL 式で追加して、リクエストメッセージに対してその値を評価します。
      パラメーター:
      name - パラメーターの名前。
      expression - パラメーター値の SpEL 式。
      戻り値:
      このスペック

    • parameter

      public CassandraMessageHandlerSpec parameter(StringSE name, FunctionSE<Message<?>,?> function)
      リクエストメッセージに対してその値を評価する関数を使用して、名前付きのバインド可能なパラメーターを追加します。
      パラメーター:
      name - パラメーターの名前。
      function - パラメーター値の関数。
      戻り値:
      このスペック

    • parameter

      public CassandraMessageHandlerSpec parameter(StringSE name, Expression expression)
      名前付きバインド可能パラメーターを SpEL 式で追加して、リクエストメッセージに対してその値を評価します。
      パラメーター:
      name - パラメーターの名前。
      expression - パラメーター値の SpEL 式。
      戻り値:
      このスペック