パッケージ org.springframework.pulsar.core

クラス DefaultSchemaResolver

java.lang.ObjectSE
org.springframework.pulsar.core.DefaultSchemaResolver
実装されたすべてのインターフェース:
SchemaResolver
public class DefaultSchemaResolver extends ObjectSE implements SchemaResolver
基本的なメッセージ型を処理できるデフォルトのスキーマリゾルバー。

追加のメッセージ型は addCustomSchemaMapping(Class, Schema) で構成できます。

作成者:
Soby Chacko, Alexander Preu ß , Chris Bono

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

    • DefaultSchemaResolver

      public DefaultSchemaResolver()

  • メソッドの詳細

    • addCustomSchemaMapping

      @Nullable public org.apache.pulsar.client.api.Schema<?> addCustomSchemaMapping(ClassSE<?> messageType, org.apache.pulsar.client.api.Schema<?> schema)
      メッセージ型からスキーマへのカスタムマッピングを追加します。
      パラメーター:
      messageType - メッセージ型
      schema - messageType 型のメッセージに使用するスキーマ
      戻り値:
      以前にマップされたスキーマ、または messageType のマッピングがなかった場合は null。

    • removeCustomMapping

      @Nullable public org.apache.pulsar.client.api.Schema<?> removeCustomMapping(ClassSE<?> messageType)
      メッセージ型からスキーマへのカスタムマッピングを削除します。
      パラメーター:
      messageType - メッセージ型
      戻り値:
      以前にマップされたスキーマ、または messageType のマッピングがなかった場合は null。

    • getCustomSchemaMappings

      public MapSE<ClassSE<?>,org.apache.pulsar.client.api.Schema<?>> getCustomSchemaMappings()
      メッセージ型からスキーマへの現在登録されているカスタムマッピングを取得します。
      戻り値:
      カスタムマッピングの変更不可能なマップ

    • resolveSchema

      public <T> Resolved<org.apache.pulsar.client.api.Schema<T>> resolveSchema(@Nullable ClassSE<?> messageClass, boolean returnDefault)
      インターフェースからコピーされた説明: SchemaResolver
      メッセージ型に使用するスキーマを取得します。
      次で指定:
      インターフェース SchemaResolver の resolveSchema 
      型パラメーター:
      T - スキーマの型
      パラメーター:
      messageClass - メッセージ型
      returnDefault - スキーマを解決できなかった場合にデフォルトのスキーマを返すかどうか
      戻り値:
      使用するスキーマ、またはスキーマを解決できず、returnDefault が true の場合はデフォルトのスキーマ、それ以外の場合は null

    • getCustomSchemaOrMaybeDefault

      @Nullable protected org.apache.pulsar.client.api.Schema<?> getCustomSchemaOrMaybeDefault(@Nullable ClassSE<?> messageClass, boolean returnDefault)

    • resolveSchema

      public <T> Resolved<org.apache.pulsar.client.api.Schema<T>> resolveSchema(org.apache.pulsar.common.schema.SchemaType schemaType, @Nullable ResolvableType messageType)
      インターフェースからコピーされた説明: SchemaResolver
      指定されたスキーマ型とメッセージ型を指定して、使用するスキーマを取得します。
      次で指定:
      インターフェース SchemaResolver の resolveSchema 
      型パラメーター:
      T - スキーマの型
      パラメーター:
      schemaType - スキーマの型
      messageType - メッセージ型
      戻り値:
      使用するスキーマ