クラス PulsarTemplate<T>
java.lang.ObjectSE
org.springframework.pulsar.core.PulsarTemplate<T>
- 型パラメーター:
T
- メッセージのペイロード型
- 実装されたすべてのインターフェース:
Aware
、BeanNameAware
、SmartInitializingSingleton
、ApplicationContextAware
、PulsarOperations<T>
public class PulsarTemplate<T>
extends ObjectSE
implements PulsarOperations<T>, ApplicationContextAware, BeanNameAware, SmartInitializingSingleton
高レベルの Pulsar 操作を実行するためのテンプレート。
- 作成者:
- Soby Chacko, Chris Bono, Alexander Preu ß , Christophe Bornet, Jonas Geiregat
ネストされたクラスのサマリー
修飾子と型クラス説明static class
static interface
PulsarTemplate
で任意の操作を実行するためのコールバック。インターフェース org.springframework.pulsar.core.PulsarOperations から継承されたネストクラス / インターフェース
PulsarOperations.SendMessageBuilder<T>
コンストラクターのサマリー
コンストラクター説明PulsarTemplate
(PulsarProducerFactory<T> producerFactory) インターセプターなしで、デフォルトのスキーマリゾルバーを使用するテンプレートインスタンスを構築します。PulsarTemplate
(PulsarProducerFactory<T> producerFactory, ListSE<org.apache.pulsar.client.api.interceptor.ProducerInterceptor> interceptors) デフォルトのスキーマリゾルバーとデフォルトのトピックリゾルバーを使用し、観察記録を有効にするインターセプターを含むテンプレートインスタンスを構築します。PulsarTemplate
(PulsarProducerFactory<T> producerFactory, ListSE<org.apache.pulsar.client.api.interceptor.ProducerInterceptor> interceptors, SchemaResolver schemaResolver, TopicResolver topicResolver, boolean observationEnabled) オプションの監視構成を使用してテンプレートインスタンスを構築します。メソッドのサマリー
修飾子と型メソッド説明void
観察が有効な場合は、観察レジストリと規則の取得を試みます。<R> R
executeInTransaction
(PulsarTemplate.TemplateCallback<T, R> callback) テンプレートに対して任意の操作を実行し、結果を返します。newMessage
(T message) メッセージを構成して送信するためのbuilder
を作成します。org.apache.pulsar.client.api.MessageId
指定されたトピックにブロック方式でメッセージを送信します。org.apache.pulsar.client.api.MessageId
指定されたトピックにブロック方式でメッセージを送信します。org.apache.pulsar.client.api.MessageId
ブロック方式でデフォルトのトピックにメッセージを送信します。org.apache.pulsar.client.api.MessageId
ブロック方式でデフォルトのトピックにメッセージを送信します。CompletableFutureSE<org.apache.pulsar.client.api.MessageId>
指定されたトピックに非ブロック的な方法でメッセージを送信します。CompletableFutureSE<org.apache.pulsar.client.api.MessageId>
指定されたトピックに非ブロック的な方法でメッセージを送信します。CompletableFutureSE<org.apache.pulsar.client.api.MessageId>
非ブロック的な方法でデフォルトのトピックにメッセージを送信します。CompletableFutureSE<org.apache.pulsar.client.api.MessageId>
非ブロック的な方法でデフォルトのトピックにメッセージを送信します。void
setApplicationContext
(ApplicationContext applicationContext) void
setBeanName
(StringSE beanName) トランザクションのプロパティを取得します。
コンストラクターの詳細
PulsarTemplate
インターセプターなしで、デフォルトのスキーマリゾルバーを使用するテンプレートインスタンスを構築します。- パラメーター:
producerFactory
- バックの Pulsar プロデューサーを作成するために使用されるファクトリ。
PulsarTemplate
public PulsarTemplate(PulsarProducerFactory<T> producerFactory, ListSE<org.apache.pulsar.client.api.interceptor.ProducerInterceptor> interceptors) デフォルトのスキーマリゾルバーとデフォルトのトピックリゾルバーを使用し、観察記録を有効にするインターセプターを含むテンプレートインスタンスを構築します。- パラメーター:
producerFactory
- バックの Pulsar プロデューサーを作成するために使用されるファクトリ。interceptors
- プロデューサーに追加するインターセプター。
PulsarTemplate
public PulsarTemplate(PulsarProducerFactory<T> producerFactory, ListSE<org.apache.pulsar.client.api.interceptor.ProducerInterceptor> interceptors, SchemaResolver schemaResolver, TopicResolver topicResolver, boolean observationEnabled) オプションの監視構成を使用してテンプレートインスタンスを構築します。- パラメーター:
producerFactory
- バッキング Pulsar プロデューサーの作成に使用されるファクトリinterceptors
- プロデューサーに追加するインターセプタのリストschemaResolver
- 使用するスキーマリゾルバーtopicResolver
- 使用するトピックリゾルバーobservationEnabled
- 観察を記録するかどうか
メソッドの詳細
setApplicationContext
- 次で指定:
- インターフェース
ApplicationContextAware
のsetApplicationContext
transactions
トランザクションのプロパティを取得します。- 戻り値:
- トランザクションプロパティ
- 導入:
- 1.1.0
afterSingletonsInstantiated
public void afterSingletonsInstantiated()観察が有効な場合は、観察レジストリと規則の取得を試みます。- 次で指定:
- インターフェース
SmartInitializingSingleton
のafterSingletonsInstantiated
send
インターフェースからコピーされた説明:PulsarOperations
ブロック方式でデフォルトのトピックにメッセージを送信します。- 次で指定:
- インターフェース
PulsarOperations<T>
のsend
- パラメーター:
message
- 送信するメッセージ- 戻り値:
- パブリッシュされたメッセージにブローカーによって割り当てられた ID
send
public org.apache.pulsar.client.api.MessageId send(@Nullable T message, @Nullable org.apache.pulsar.client.api.Schema<T> schema) インターフェースからコピーされた説明:PulsarOperations
ブロック方式でデフォルトのトピックにメッセージを送信します。- 次で指定:
- インターフェース
PulsarOperations<T>
のsend
- パラメーター:
message
- 送信するメッセージschema
- 使用するスキーマ、またはデフォルトのスキーマ解決を使用して送信するnull
- 戻り値:
- パブリッシュされたメッセージにブローカーによって割り当てられた ID
send
インターフェースからコピーされた説明:PulsarOperations
指定されたトピックにブロック方式でメッセージを送信します。- 次で指定:
- インターフェース
PulsarOperations<T>
のsend
- パラメーター:
topic
- メッセージの送信先のトピック、またはデフォルトのトピックに送信するnull
message
- 送信するメッセージ- 戻り値:
- パブリッシュされたメッセージにブローカーによって割り当てられた ID
send
public org.apache.pulsar.client.api.MessageId send(@Nullable StringSE topic, @Nullable T message, @Nullable org.apache.pulsar.client.api.Schema<T> schema) インターフェースからコピーされた説明:PulsarOperations
指定されたトピックにブロック方式でメッセージを送信します。- 次で指定:
- インターフェース
PulsarOperations<T>
のsend
- パラメーター:
topic
- メッセージの送信先のトピック、またはデフォルトのトピックに送信するnull
message
- 送信するメッセージschema
- 使用するスキーマ、またはデフォルトのスキーマ解決を使用して送信するnull
- 戻り値:
- パブリッシュされたメッセージにブローカーによって割り当てられた ID
sendAsync
インターフェースからコピーされた説明:PulsarOperations
非ブロック的な方法でデフォルトのトピックにメッセージを送信します。- 次で指定:
- インターフェース
PulsarOperations<T>
のsendAsync
- パラメーター:
message
- 送信するメッセージ- 戻り値:
- パブリッシュされたメッセージにブローカーによって割り当てられた ID を保持する Future
sendAsync
public CompletableFutureSE<org.apache.pulsar.client.api.MessageId> sendAsync(@Nullable T message, @Nullable org.apache.pulsar.client.api.Schema<T> schema) インターフェースからコピーされた説明:PulsarOperations
非ブロック的な方法でデフォルトのトピックにメッセージを送信します。- 次で指定:
- インターフェース
PulsarOperations<T>
のsendAsync
- パラメーター:
message
- 送信するメッセージschema
- 使用するスキーマ、またはデフォルトのスキーマ解決を使用して送信するnull
- 戻り値:
- パブリッシュされたメッセージにブローカーによって割り当てられた ID を保持する Future
sendAsync
public CompletableFutureSE<org.apache.pulsar.client.api.MessageId> sendAsync(@Nullable StringSE topic, @Nullable T message) インターフェースからコピーされた説明:PulsarOperations
指定されたトピックに非ブロック的な方法でメッセージを送信します。- 次で指定:
- インターフェース
PulsarOperations<T>
のsendAsync
- パラメーター:
topic
- メッセージの送信先のトピック、またはデフォルトのトピックに送信するnull
message
- 送信するメッセージ- 戻り値:
- パブリッシュされたメッセージにブローカーによって割り当てられた ID を保持する Future
sendAsync
public CompletableFutureSE<org.apache.pulsar.client.api.MessageId> sendAsync(@Nullable StringSE topic, @Nullable T message, @Nullable org.apache.pulsar.client.api.Schema<T> schema) インターフェースからコピーされた説明:PulsarOperations
指定されたトピックに非ブロック的な方法でメッセージを送信します。- 次で指定:
- インターフェース
PulsarOperations<T>
のsendAsync
- パラメーター:
topic
- メッセージの送信先のトピック、またはデフォルトのトピックに送信するnull
message
- 送信するメッセージschema
- 使用するスキーマ、またはデフォルトのスキーマ解決を使用して送信するnull
- 戻り値:
- パブリッシュされたメッセージにブローカーによって割り当てられた ID を保持する Future
newMessage
インターフェースからコピーされた説明:PulsarOperations
メッセージを構成して送信するためのbuilder
を作成します。- 次で指定:
- インターフェース
PulsarOperations<T>
のnewMessage
- パラメーター:
message
- メッセージのペイロード- 戻り値:
- メッセージを構成して送信するビルダー
setBeanName
- 次で指定:
- インターフェース
BeanNameAware
のsetBeanName
executeInTransaction
テンプレートに対して任意の操作を実行し、結果を返します。テンプレートはローカルトランザクション内で呼び出され、グローバルトランザクション (存在する場合) には参加しません。- 型パラメーター:
R
- コールバックの戻り値の型- パラメーター:
callback
- コールバック- 戻り値:
- 結果
- 導入:
- 1.1.0