インターフェースの使用
org.springframework.pulsar.core.SchemaResolver
パッケージ
説明
フレームワークのコアコンポーネントを含むパッケージ。
Pulsar メッセージを受信するためのリスナーコンポーネントを含むパッケージ。
フレームワークのコアリアクティブコンポーネントを含むパッケージ。
Pulsar メッセージを受信するためのリスナーコンポーネントを含むパッケージ。
org.springframework.pulsar.core 内の SchemaResolver 使用
修飾子と型インターフェース説明static interface
スキーマリゾルバーが完全に初期化される前に、特に構成を調整するためにスキーマリゾルバーをカスタマイズしたい Bean によって実装できるコールバックインターフェース。修飾子コンストラクター説明PulsarTemplate
(PulsarProducerFactory<T> producerFactory, ListSE<org.apache.pulsar.client.api.interceptor.ProducerInterceptor> interceptors, SchemaResolver schemaResolver, TopicResolver topicResolver, boolean observationEnabled) オプションの監視構成を使用してテンプレートインスタンスを構築します。org.springframework.pulsar.listener 内の SchemaResolver 使用
org.springframework.pulsar.reactive.core 内の SchemaResolver 使用
修飾子コンストラクター説明ReactivePulsarTemplate
(ReactivePulsarSenderFactory<T> reactiveMessageSenderFactory, SchemaResolver schemaResolver, TopicResolver topicResolver) カスタムスキーマリゾルバーとカスタムトピックリゾルバーを使用してテンプレートインスタンスを構築します。org.springframework.pulsar.reactive.listener 内の SchemaResolver 使用
修飾子と型メソッド説明void
ReactivePulsarContainerProperties.setSchemaResolver
(SchemaResolver schemaResolver) org.springframework.pulsar.reader 内の SchemaResolver 使用