パッケージ org.springframework.kafka.support.converter

クラス ProjectingMessageConverter

java.lang.ObjectSE
org.springframework.kafka.support.converter.MessagingMessageConverter
org.springframework.kafka.support.converter.ProjectingMessageConverter
実装されたすべてのインターフェース:
MessageConverter, RecordMessageConverter
public class ProjectingMessageConverter extends MessagingMessageConverter
Spring Data ProjectionFactory を使用して受信メッセージを射影インターフェースにバインドする MessageConverter 実装。
導入:
2.1.1
作成者:
Oliver Gierke, Artem Bilan, Gary Russell

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

    • ProjectingMessageConverter

      public ProjectingMessageConverter()
      デフォルトで JacksonUtils.enhancedObjectMapper() を使用して新しい ProjectingMessageConverter を作成します。
      導入:
      2.3

    • ProjectingMessageConverter

      public ProjectingMessageConverter(com.fasterxml.jackson.databind.ObjectMapper mapper)
      指定された ObjectMapper を使用して新しい ProjectingMessageConverter を作成します。
      パラメーター:
      mapper - null であってはなりません。

    • ProjectingMessageConverter

      public ProjectingMessageConverter(MessagingMessageConverter delegate)
      指定された ObjectMapper を使用して新しい ProjectingMessageConverter を作成します。
      パラメーター:
      delegate - 送信および非インターフェース用のデリゲートコンバーター。
      導入:
      2.3

    • ProjectingMessageConverter

      public ProjectingMessageConverter(com.fasterxml.jackson.databind.ObjectMapper mapper, MessagingMessageConverter delegate)
      指定された ObjectMapper を使用して新しい ProjectingMessageConverter を作成します。
      パラメーター:
      mapper - null であってはなりません。
      delegate - 送信および非インターフェース用のデリゲートコンバーター。
      導入:
      2.3

  • メソッドの詳細

    • convertPayload

      protected ObjectSE convertPayload(Message<?> message)
      クラスからコピーされた説明: MessagingMessageConverter
      サブクラスはペイロードを変換できます。デフォルトでは、変更されずに Kafka に送信されます。
      オーバーライド:
      クラス MessagingMessageConverter の convertPayload 
      パラメーター:
      message - メッセージ。
      戻り値:
      ペイロード。

    • extractAndConvertValue

      protected ObjectSE extractAndConvertValue(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, TypeSE type)
      クラスからコピーされた説明: MessagingMessageConverter
      サブクラスは値を変換できます。デフォルトでは、変換できる SmartMessageConverter がない限り、Kafka によって提供されるものとして返されます。
      オーバーライド:
      クラス MessagingMessageConverter の extractAndConvertValue 
      パラメーター:
      record - レコード。
      type - 必要な型。
      戻り値:
      値。