クラス DefaultPulsarConsumerFactory<T>
java.lang.ObjectSE
org.springframework.pulsar.core.DefaultPulsarConsumerFactory<T>
- 型パラメーター:
T
- コンシューマーの基礎となるペイロード型。
- 実装されたすべてのインターフェース:
PulsarConsumerFactory<T>
PulsarConsumerFactory
のデフォルト実装。- 作成者:
- Soby Chacko, Alexander Preu ß , Christophe Bornet, Chris Bono, Jonas Geiregat
コンストラクターのサマリー
コンストラクター説明DefaultPulsarConsumerFactory
(org.apache.pulsar.client.api.PulsarClient pulsarClient, ListSE<ConsumerBuilderCustomizer<T>> defaultConfigCustomizers) コンシューマーファクトリインスタンスを構築します。メソッドのサマリー
修飾子と型メソッド説明org.apache.pulsar.client.api.Consumer<T>
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>
createConsumer
(org.apache.pulsar.client.api.Schema<T> schema, CollectionSE<StringSE> topics, StringSE subscriptionName, ConsumerBuilderCustomizer<T> customizer) コンシューマーを作成します。
コンストラクターの詳細
DefaultPulsarConsumerFactory
public DefaultPulsarConsumerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient, ListSE<ConsumerBuilderCustomizer<T>> defaultConfigCustomizers) コンシューマーファクトリインスタンスを構築します。- パラメーター:
pulsarClient
- クライアントが消費していたdefaultConfigCustomizers
- 作成されたコンシューマーに適用するカスタマイザーのオプションのリスト、またはデフォルト構成を使用しない場合は null
メソッドの詳細
createConsumer
public org.apache.pulsar.client.api.Consumer<T> createConsumer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable CollectionSE<StringSE> topics, @Nullable StringSE subscriptionName, ConsumerBuilderCustomizer<T> customizer) インターフェースからコピーされた説明:PulsarConsumerFactory
コンシューマーを作成します。- 次で指定:
- インターフェース
PulsarConsumerFactory<T>
のcreateConsumer
- パラメーター:
schema
- 送信されるメッセージのスキーマtopics
- コンシューマーがサブスクライブするトピック、デフォルトのトピックを置き換えるか、null
がデフォルトのトピックを使用します。ConsumerBuilder.topic(java.lang.String...)
またはConsumerBuilder.topics(java.util.List<java.lang.String>)
を使用すると、デフォルトのトピックが上書きされるのではなく、追加されることに注意してください。また、デフォルトのトピックが設定されていないときにnull
を指定すると例外が発生することに注意してください。subscriptionName
- 消費されたトピックへのサブスクリプションに使用する名前、またはデフォルトの構成済みサブスクリプション名を使用するnull
。デフォルトのサブスクリプション名が構成されていない場合にnull
を指定すると、例外が発生することに注意してください。customizer
- Consumer Builder に適用するオプションのカスタマイザー。カスタマイザは最後に適用され、指定されたパラメーターやデフォルトのプロパティをオーバーライドする可能性があることに注意してください。- 戻り値:
- コンシューマー
createConsumer
public org.apache.pulsar.client.api.Consumer<T> createConsumer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable CollectionSE<StringSE> topics, @Nullable StringSE subscriptionName, @Nullable MapSE<StringSE, StringSE> metadataProperties, @Nullable ListSE<ConsumerBuilderCustomizer<T>> customizers) インターフェースからコピーされた説明:PulsarConsumerFactory
コンシューマーを作成します。- 次で指定:
- インターフェース
PulsarConsumerFactory<T>
のcreateConsumer
- パラメーター:
schema
- 送信されるメッセージのスキーマtopics
- コンシューマーがサブスクライブするトピック、デフォルトのトピックを置き換えるか、null
がデフォルトのトピックを使用します。ConsumerBuilder.topic(java.lang.String...)
またはConsumerBuilder.topics(java.util.List<java.lang.String>)
を使用すると、デフォルトのトピックが上書きされるのではなく、追加されることに注意してください。また、デフォルトのトピックが設定されていないときにnull
を指定すると例外が発生することに注意してください。subscriptionName
- 消費されたトピックへのサブスクリプションに使用する名前、またはデフォルトの構成済みサブスクリプション名を使用するnull
。デフォルトのサブスクリプション名が構成されていない場合にnull
を指定すると、例外が発生することに注意してください。metadataProperties
- デフォルトのメタデータプロパティを置き換えてコンシューマーに添付するメタデータプロパティ、またはデフォルトのメタデータプロパティを使用するnull
。ConsumerBuilder.property(java.lang.String, java.lang.String)
またはConsumerBuilder.properties(java.util.Map<java.lang.String, java.lang.String>)
を使用すると、デフォルトのメタデータプロパティが置き換えられるのではなく、追加されることに注意してください。customizers
- Consumer Builder に適用するカスタマイザーのオプションのリスト。カスタマイザは最後に適用され、指定されたパラメーターやデフォルトのプロパティをオーバーライドする可能性があることに注意してください。- 戻り値:
- コンシューマー