インターフェースの使用
org.springframework.pulsar.core.TopicResolver
パッケージ
説明
フレームワークのコアコンポーネントを含むパッケージ。
Pulsar メッセージを受信するためのリスナーコンポーネントを含むパッケージ。
フレームワークのコアリアクティブコンポーネントを含むパッケージ。
Pulsar メッセージを受信するためのリスナーコンポーネントを含むパッケージ。
org.springframework.pulsar.core 内の TopicResolver 使用
修飾子コンストラクター説明CachingPulsarProducerFactory
(org.apache.pulsar.client.api.PulsarClient pulsarClient, StringSE defaultTopic, ListSE<ProducerBuilderCustomizer<T>> defaultConfigCustomizers, TopicResolver topicResolver, DurationSE cacheExpireAfterAccess, LongSE cacheMaximumSize, IntegerSE cacheInitialCapacity) キャッシュ構成に指定された値を使用してキャッシュプロデューサーファクトリを構築します。DefaultPulsarProducerFactory
(org.apache.pulsar.client.api.PulsarClient pulsarClient, StringSE defaultTopic, ListSE<ProducerBuilderCustomizer<T>> defaultConfigCustomizers, TopicResolver topicResolver) 指定されたパラメーターを使用するプロデューサーファクトリを構築します。PulsarTemplate
(PulsarProducerFactory<T> producerFactory, ListSE<org.apache.pulsar.client.api.interceptor.ProducerInterceptor> interceptors, SchemaResolver schemaResolver, TopicResolver topicResolver, boolean observationEnabled) オプションの監視構成を使用してテンプレートインスタンスを構築します。org.springframework.pulsar.listener 内の TopicResolver 使用
org.springframework.pulsar.reactive.core 内の TopicResolver 使用
修飾子と型メソッド説明DefaultReactivePulsarSenderFactory.Builder.withTopicResolver
(TopicResolver topicResolver) 使用するトピックリゾルバーを指定します。修飾子コンストラクター説明ReactivePulsarTemplate
(ReactivePulsarSenderFactory<T> reactiveMessageSenderFactory, SchemaResolver schemaResolver, TopicResolver topicResolver) カスタムスキーマリゾルバーとカスタムトピックリゾルバーを使用してテンプレートインスタンスを構築します。org.springframework.pulsar.reactive.listener 内の TopicResolver 使用