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

クラス CassandraMessageHandler

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.handler.AbstractMessageProducingHandler
org.springframework.integration.handler.AbstractReplyProducingMessageHandler
org.springframework.integration.cassandra.outbound.CassandraMessageHandler
実装されたすべてのインターフェース:
org.reactivestreams.Subscriber<Message<?>>、Aware、BeanClassLoaderAware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、Ordered、ComponentSourceAware、ExpressionCapable、Orderable、MessageProducer、HeaderPropagationAware、IntegrationPattern、NamedComponent、IntegrationManagement、TrackableComponent、MessageHandler、reactor.core.CoreSubscriber<Message<?>>
public class CassandraMessageHandler extends AbstractReplyProducingMessageHandler
Cassandra 送信操作の AbstractReplyProducingMessageHandler 実装。
導入:
6.0
作成者:
Soby Chacko, Artem Bilan, Filippo Balicchia, Ngoc Nhan

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

    • CassandraMessageHandler

      public CassandraMessageHandler(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations)

    • CassandraMessageHandler

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

  • メソッドの詳細

    • setIngestQuery

      public void setIngestQuery(StringSE ingestQuery)

    • setWriteOptions

      public void setWriteOptions(org.springframework.data.cassandra.core.cql.WriteOptions writeOptions)

    • setProducesReply

      public void setProducesReply(boolean producesReply)

    • setStatementExpressionString

      public void setStatementExpressionString(StringSE statementExpression)

    • setStatementExpression

      public void setStatementExpression(Expression statementExpression)

    • setQuery

      public void setQuery(StringSE query)

    • setParameterExpressions

      public void setParameterExpressions(MapSE<StringSE,Expression> parameterExpressions)

    • setStatementProcessor

      public void setStatementProcessor(MessageProcessor<com.datastax.oss.driver.api.core.cql.Statement<?>> statementProcessor)

    • getComponentType

      public StringSE getComponentType()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
      次で指定:
      インターフェース NamedComponent の getComponentType 
      オーバーライド:
      クラス MessageHandlerSupport の getComponentType 

    • doInit

      protected void doInit()
      オーバーライド:
      クラス AbstractReplyProducingMessageHandler の doInit 

    • handleRequestMessage

      protected ObjectSE handleRequestMessage(Message<?> requestMessage)
      クラスからコピーされた説明: AbstractReplyProducingMessageHandler
      サブクラスはこのメソッドを実装して、リクエストメッセージを処理する必要があります。戻り値は、メッセージ、MessageBuilder、任意のプレーンオブジェクトです。基本クラスは、これらの開始点のいずれかからの返信メッセージの最終的な作成を処理します。戻り値が null の場合、メッセージフローはここで終了します。
      次で指定:
      クラス AbstractReplyProducingMessageHandler の handleRequestMessage 
      パラメーター:
      requestMessage - リクエストメッセージ。
      戻り値:
      メッセージを処理した結果、または null