クラス DefaultSchemaResolver
java.lang.ObjectSE
org.springframework.pulsar.core.DefaultSchemaResolver
- 実装されたすべてのインターフェース:
SchemaResolver
基本的なメッセージ型を処理できるデフォルトのスキーマリゾルバー。
追加のメッセージ型は addCustomSchemaMapping(Class, Schema)
で構成できます。
- 作成者:
- Soby Chacko, Alexander Preu ß , Chris Bono, Aleksei Arsenev
ネストされたクラスのサマリー
インターフェース org.springframework.pulsar.core.SchemaResolver から継承されたネストクラス / インターフェース
SchemaResolver.SchemaResolverCustomizer<T extends SchemaResolver>
コンストラクターのサマリー
メソッドのサマリー
修飾子と型メソッド説明org.apache.pulsar.client.api.Schema<?>
addCustomSchemaMapping
(ClassSE<?> messageType, org.apache.pulsar.client.api.Schema<?> schema) メッセージ型からスキーマへのカスタムマッピングを追加します。メッセージ型からスキーマへの現在登録されているカスタムマッピングを取得します。protected org.apache.pulsar.client.api.Schema<?>
getCustomSchemaOrMaybeDefault
(ClassSE<?> messageClass, boolean returnDefault) org.apache.pulsar.client.api.Schema<?>
removeCustomMapping
(ClassSE<?> messageType) メッセージ型からスキーマへのカスタムマッピングを削除します。<T> Resolved<org.apache.pulsar.client.api.Schema<T>>
resolveSchema
(ClassSE<?> messageClass, boolean returnDefault) メッセージ型に使用するスキーマを取得します。<T> Resolved<org.apache.pulsar.client.api.Schema<T>>
resolveSchema
(org.apache.pulsar.common.schema.SchemaType schemaType, ResolvableType messageType) 指定されたスキーマ型とメッセージ型を指定して、使用するスキーマを取得します。void
usePulsarMessageAnnotations
(boolean usePulsarMessageAnnotations) スキーマ解決中に@PulsarMessage
アノテーションのメッセージクラスをインスペクションするかどうかを設定します。クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.pulsar.core.SchemaResolver から継承されたメソッド
resolveSchema, resolveSchema, resolveSchema
コンストラクターの詳細
DefaultSchemaResolver
public DefaultSchemaResolver()
メソッドの詳細
usePulsarMessageAnnotations
public void usePulsarMessageAnnotations(boolean usePulsarMessageAnnotations) スキーマ解決中に@PulsarMessage
アノテーションのメッセージクラスをインスペクションするかどうかを設定します。- パラメーター:
usePulsarMessageAnnotations
- アノテーションのメッセージをインスペクションするかどうか
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
メッセージ型からスキーマへのカスタムマッピングを削除します。- パラメーター:
messageType
- メッセージ型- 戻り値:
- 以前にマップされたスキーマ、または
messageType
のマッピングがなかった場合はnull
。
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
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
- メッセージ型- 戻り値:
- 使用するスキーマ