インターフェースの使用
org.springframework.pulsar.core.ConsumerBuilderCustomizer
パッケージ
説明
フレームワークの Spring 構成クラスを含むパッケージ。
フレームワークのコアコンポーネントを含むパッケージ。
Pulsar メッセージを受信するためのリスナーコンポーネントを含むパッケージ。
org.springframework.pulsar.config 内の ConsumerBuilderCustomizer 使用
修飾子と型メソッド説明void
MethodPulsarListenerEndpoint.setConsumerBuilderCustomizer
(ConsumerBuilderCustomizer<?> consumerBuilderCustomizer) org.springframework.pulsar.core 内の ConsumerBuilderCustomizer 使用
修飾子と型メソッド説明org.apache.pulsar.client.api.Consumer<T>
DefaultPulsarConsumerFactory.createConsumer
(org.apache.pulsar.client.api.Schema<T> schema, CollectionSE<StringSE> topics, StringSE subscriptionName, ConsumerBuilderCustomizer<T> customizer) org.apache.pulsar.client.api.Consumer<T>
PulsarConsumerFactory.createConsumer
(org.apache.pulsar.client.api.Schema<T> schema, CollectionSE<StringSE> topics, StringSE subscriptionName, ConsumerBuilderCustomizer<T> customizer) コンシューマーを作成します。修飾子と型メソッド説明org.apache.pulsar.client.api.Consumer<T>
DefaultPulsarConsumerFactory.createConsumer
(org.apache.pulsar.client.api.Schema<T> schema, CollectionSE<StringSE> topics, StringSE subscriptionName, MapSE<StringSE, StringSE> metadataProperties, ListSE<ConsumerBuilderCustomizer<T>> customizers) org.apache.pulsar.client.api.Consumer<T>
PulsarConsumerFactory.createConsumer
(org.apache.pulsar.client.api.Schema<T> schema, CollectionSE<StringSE> topics, StringSE subscriptionName, MapSE<StringSE, StringSE> metadataProperties, ListSE<ConsumerBuilderCustomizer<T>> customizers) コンシューマーを作成します。修飾子コンストラクター説明DefaultPulsarConsumerFactory
(org.apache.pulsar.client.api.PulsarClient pulsarClient, ListSE<ConsumerBuilderCustomizer<T>> defaultConfigCustomizers) コンシューマーファクトリインスタンスを構築します。org.springframework.pulsar.listener 内の ConsumerBuilderCustomizer 使用
修飾子と型フィールド説明protected ConsumerBuilderCustomizer<T>
AbstractPulsarMessageListenerContainer.consumerBuilderCustomizer
修飾子と型メソッド説明void
AbstractPulsarMessageListenerContainer.setConsumerCustomizer
(ConsumerBuilderCustomizer<?> consumerBuilderCustomizer) void
PulsarMessageListenerContainer.setConsumerCustomizer
(ConsumerBuilderCustomizer<?> consumerBuilderCustomizer) このコンテナーにコンシューマーカスタマイザを設定します。