クラス PulsarAdministration
java.lang.ObjectSE
org.springframework.pulsar.core.PulsarAdministration
- 実装されたすべてのインターフェース:
Aware
、SmartInitializingSingleton
、ApplicationContextAware
、PulsarAdministrationOperations
public class PulsarAdministration
extends ObjectSE
implements ApplicationContextAware, SmartInitializingSingleton, PulsarAdministrationOperations
アプリケーションコンテキストで定義されたトピックの作成と管理を
PulsarAdmin
に委譲する管理クラス。- 作成者:
- Alexander Preu ß , Chris Bono, Kirill Merkushev
コンストラクターのサマリー
コンストラクター説明PulsarAdministration
(StringSE serviceHttpUrl) 指定されたサービス URL を使用してデフォルトのインスタンスを構築します。PulsarAdministration
(ListSE<PulsarAdminBuilderCustomizer> adminCustomizers) 指定されたカスタマイズを使用してインスタンスを構築します。PulsarAdministration
(PulsarAdminBuilderCustomizer adminCustomizer) 指定されたカスタマイズを使用してインスタンスを構築します。メソッドのサマリー
修飾子と型メソッド説明void
org.apache.pulsar.client.admin.PulsarAdmin
void
createOrModifyTopics
(PulsarTopic... topics) 指定されたトピックを作成または変更します。void
setApplicationContext
(ApplicationContext applicationContext)
コンストラクターの詳細
PulsarAdministration
指定されたサービス URL を使用してデフォルトのインスタンスを構築します。- パラメーター:
serviceHttpUrl
- 管理者の http サービス URL
PulsarAdministration
指定されたカスタマイズを使用してインスタンスを構築します。- パラメーター:
adminCustomizer
- ビルダーに適用するカスタマイザー、または変更せずにデフォルトの管理ビルダーを使用する場合は null
PulsarAdministration
指定されたカスタマイズを使用してインスタンスを構築します。- パラメーター:
adminCustomizers
- ビルダーに適用するカスタマイザー、または変更せずにデフォルトの管理ビルダーを使用する場合は null
メソッドの詳細
afterSingletonsInstantiated
public void afterSingletonsInstantiated()- 次で指定:
- インターフェース
SmartInitializingSingleton
のafterSingletonsInstantiated
setApplicationContext
- 次で指定:
- インターフェース
ApplicationContextAware
のsetApplicationContext
- 例外:
BeansException
createAdminClient
public org.apache.pulsar.client.admin.PulsarAdmin createAdminClient() throws org.apache.pulsar.client.api.PulsarClientException- 例外:
org.apache.pulsar.client.api.PulsarClientException
createOrModifyTopics
インターフェースからコピーされた説明:PulsarAdministrationOperations
指定されたトピックを作成または変更します。- 次で指定:
- インターフェース
PulsarAdministrationOperations
のcreateOrModifyTopics
- パラメーター:
topics
- 作成または変更するトピック