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

クラス KafkaMessageHeaderAccessor

java.lang.ObjectSE
org.springframework.messaging.support.MessageHeaderAccessor
org.springframework.kafka.support.KafkaMessageHeaderAccessor
public class KafkaMessageHeaderAccessor extends MessageHeaderAccessor
ヘッダーアクセサーは、型固有の方法で特定のヘッダーに簡単にアクセスできるようにします。
導入:
3.0.10
作成者:
Gary Russell

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

    • KafkaMessageHeaderAccessor

      public KafkaMessageHeaderAccessor(Message<?> message)
      提供されたメッセージのインスタンスを構築します。
      パラメーター:
      message - メッセージ。

  • メソッドの詳細

    • getBlockingRetryDeliveryAttempt

      public int getBlockingRetryDeliveryAttempt()
      ブロック配信試行ヘッダーが存在する場合は、ヘッダー値にアクセスします。
      戻り値:
      ヘッダーが存在しない場合は 1。それ以外の場合は、デコードされたヘッダー値。
      例外:
      IllegalStateExceptionSE - ヘッダーが存在しない場合。
      関連事項:

    • getNonBlockingRetryDeliveryAttempt

      public int getNonBlockingRetryDeliveryAttempt()
      ノンブロッキング再試行を使用する場合は、配信試行ヘッダー値を int として取得します。
      戻り値:
      ヘッダーが存在しない場合は 1。それ以外の場合は、デコードされたヘッダー値。

    • getHeader

      @Nullable public <T> T getHeader(StringSE key, ClassSE<T> type)
      特定の型のヘッダー値を取得します。
      型パラメーター:
      T - 型。
      パラメーター:
      key - ヘッダー名。
      type - 型は ClassSE です。
      戻り値:
      値 (存在する場合)。
      例外:
      IllegalArgumentExceptionSE - 型が正しくない場合。

    • createAccessor

      protected MessageHeaderAccessor createAccessor(Message<?> message)
      オーバーライド:
      クラス MessageHeaderAccessor の createAccessor 

    • wrap

      public static KafkaMessageHeaderAccessor wrap(Message<?> message)
      指定されたメッセージのペイロードとヘッダーからインスタンスを作成します。
      パラメーター:
      message - メッセージ。
      戻り値:
      アクセサー。