クラス 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) 指定されたカスタマイズを使用してインスタンスを構築します。メソッドのサマリー
修飾子と型メソッド説明voidorg.apache.pulsar.client.admin.PulsarAdminvoidcreateOrModifyTopics(PulsarTopic... topics) 指定されたトピックを作成または変更します。voidsetApplicationContext(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- 作成または変更するトピック