インデックス

A

AbstractPulsarAnnotationsBeanPostProcessor - org.springframework.pulsar.annotation のクラス

Spring Pulsar のさまざまなアノテーションポストプロセッサーの基本クラスの実装。

AbstractPulsarAnnotationsBeanPostProcessor() - クラス org.springframework.pulsar.annotation. AbstractPulsarAnnotationsBeanPostProcessor のコンストラクター

AbstractPulsarAnnotationsBeanPostProcessor.ListenerScope - org.springframework.pulsar.annotation のクラス

AbstractPulsarAnnotationsBeanPostProcessor.PulsarHandlerMethodFactoryAdapter - org.springframework.pulsar.annotation のクラス

AbstractPulsarHeaderMapper<ToPulsarHeadersContextType,ToSpringHeadersContextType> - Class in org.springframework.pulsar.support.header

どのヘッダーが header matchers 経由でマップされるかを制限する基本 PulsarHeaderMapper 実装。

AbstractPulsarHeaderMapper(List<String>, List<String>) - クラス org.springframework.pulsar.support.header. AbstractPulsarHeaderMapper のコンストラクター

指定された受信パターンと送信パターンに一致するマッパーを構築します。

AbstractPulsarListenerContainerFactory< C extends AbstractPulsarMessageListenerContainer< T >, T > - Class in org.springframework.pulsar.config

基本 PulsarListenerContainerFactory 実装。

AbstractPulsarListenerContainerFactory(PulsarConsumerFactory<? super T>, PulsarContainerProperties) - クラス org.springframework.pulsar.config. AbstractPulsarListenerContainerFactory のコンストラクター

AbstractPulsarListenerEndpoint< K > - Class in org.springframework.pulsar.config

PulsarListenerEndpoint の基本実装。

AbstractPulsarListenerEndpoint() - クラス org.springframework.pulsar.config. AbstractPulsarListenerEndpoint のコンストラクター

AbstractPulsarMessageContainer - org.springframework.pulsar.core のクラス

さまざまなコンテナー実装の基本クラス。

AbstractPulsarMessageContainer() - クラス org.springframework.pulsar.core. AbstractPulsarMessageContainer のコンストラクター

AbstractPulsarMessageListenerContainer< T > - Class in org.springframework.pulsar.listener

PulsarMessageListenerContainer の基本実装。

AbstractPulsarMessageListenerContainer(PulsarConsumerFactory<? super T>, PulsarContainerProperties) - クラス org.springframework.pulsar.listener. AbstractPulsarMessageListenerContainer のコンストラクター

AbstractPulsarMessageReaderContainer< T > - Class in org.springframework.pulsar.reader

PulsarMessageReaderContainer のコア実装。

AbstractPulsarMessageReaderContainer(PulsarReaderFactory<? super T>, PulsarReaderContainerProperties) - クラス org.springframework.pulsar.reader. AbstractPulsarMessageReaderContainer のコンストラクター

AbstractPulsarMessageToSpringMessageAdapter< V > - Class in org.springframework.pulsar.listener.adapter

Pulsar メッセージからペイロードを抽出するために必要なインフラストラクチャを提供する抽象 MessageListener アダプター。

AbstractPulsarMessageToSpringMessageAdapter(Object, Method) - クラス org.springframework.pulsar.listener.adapter. AbstractPulsarMessageToSpringMessageAdapter のコンストラクター

AbstractPulsarReaderContainerFactory< C extends AbstractPulsarMessageReaderContainer< T >, T > - Class in org.springframework.pulsar.config

基本 PulsarReaderContainerFactory 実装。

AbstractPulsarReaderContainerFactory(PulsarReaderFactory<? super T>, PulsarReaderContainerProperties) - クラス org.springframework.pulsar.config. AbstractPulsarReaderContainerFactory のコンストラクター

AbstractPulsarReaderEndpoint< K > - Class in org.springframework.pulsar.config

PulsarListenerEndpoint の基本実装。

AbstractPulsarReaderEndpoint() - クラス org.springframework.pulsar.config. AbstractPulsarReaderEndpoint のコンストラクター

AbstractReactivePulsarListenerEndpoint< T > - Class in org.springframework.pulsar.reactive.config

ReactivePulsarListenerEndpoint の基本実装。

AbstractReactivePulsarListenerEndpoint() - クラス org.springframework.pulsar.reactive.config. AbstractReactivePulsarListenerEndpoint のコンストラクター

acceptIfNotNull(T, Consumer<T>) - クラス org.springframework.pulsar.support のメソッド。JavaUtils

null でない場合は、値を使用して Consumer.accept(Object)SE を呼び出します。

ackMode() - Element in annotation interface org.springframework.pulsar.annotation.PulsarListener

コンテナーのデフォルトの ACK モード BATCH をオーバーライドします。

AckMode - Enum Class in org.springframework.pulsar.listener

ack モードの列挙。

acknowledge() - Method in interface org.springframework.pulsar.listener.Acknowledgement

リスナーが操作している現在のメッセージを手動で確認します。

acknowledge(List<MessageId>) - Method in interface org.springframework.pulsar.listener.Acknowledgement

メッセージ ID に基づいてメッセージのリストを手動で確認します。

acknowledge(MessageId) - Method in interface org.springframework.pulsar.listener.Acknowledgement

メッセージ ID によって手動で確認応答します。

acknowledge(Message<T>) - Static method in class org.springframework.pulsar.reactive.support.MessageUtils

Spring メッセージを extracting で確認し、そのメッセージ ID を MessageResult.acknowledge(MessageId) に渡す便利なメソッドです。

Acknowledgement - Interface in org.springframework.pulsar.listener

手動承認の契約。

ackTimeoutRedeliveryBackoff - Variable in class org.springframework.pulsar.listener.AbstractPulsarMessageListenerContainer

ackTimeoutRedeliveryBackoff() - Element in annotation interface org.springframework.pulsar.annotation.PulsarListener

確認応答タイムアウト後のメッセージの再配信バックオフを制御するためにコンシューマーで使用する Bean 名または RedeliveryBackoff に解決される SpEL 式。

addCustomSchemaMapping(Class<?>, Schema<?>) - クラス org.springframework.pulsar.core のメソッド。DefaultSchemaResolver

メッセージ型からスキーマへのカスタムマッピングを追加します。

addCustomTopicMapping(Class<?>, String) - クラス org.springframework.pulsar.core のメソッド。DefaultTopicResolver

メッセージ型からトピックへのカスタムマッピングを追加します。

addListener(String, Object) - クラス org.springframework.pulsar.annotation のメソッド。AbstractPulsarAnnotationsBeanPostProcessor.ListenerScope

afterPropertiesSet() - クラス org.springframework.pulsar.annotation のメソッド。AbstractPulsarAnnotationsBeanPostProcessor

afterPropertiesSet() - クラス org.springframework.pulsar.config のメソッド。AbstractPulsarListenerEndpoint

afterPropertiesSet() - クラス org.springframework.pulsar.config のメソッド。AbstractPulsarReaderEndpoint

afterPropertiesSet() - クラス org.springframework.pulsar.config のメソッド。PulsarListenerEndpointRegistrar

afterPropertiesSet() - クラス org.springframework.pulsar.config のメソッド。PulsarReaderEndpointRegistrar

afterPropertiesSet() - クラス org.springframework.pulsar.reactive.config のメソッド。AbstractReactivePulsarListenerEndpoint

afterSingletonsInstantiated() - クラス org.springframework.pulsar.annotation のメソッド。PulsarListenerAnnotationBeanPostProcessor

afterSingletonsInstantiated() - クラス org.springframework.pulsar.annotation のメソッド。PulsarReaderAnnotationBeanPostProcessor

afterSingletonsInstantiated() - クラス org.springframework.pulsar.core のメソッド。PulsarAdministration

afterSingletonsInstantiated() - クラス org.springframework.pulsar.core のメソッド。PulsarTemplate

観察が有効な場合は、観察レジストリと規則の取得を試みます。

afterSingletonsInstantiated() - クラス org.springframework.pulsar.reactive.config.annotation のメソッド。ReactivePulsarListenerAnnotationBeanPostProcessor

applicationContext - Variable in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor

archive() - Method in record class org.springframework.pulsar.function.PulsarFunction

archive() - インターフェース org.springframework.pulsar.function のメソッド。PulsarFunctionOperations

関数を表すアーカイブへの URL またはパスを取得します。

archive() - Method in record class org.springframework.pulsar.function.PulsarSink

archive() - Method in record class org.springframework.pulsar.function.PulsarSource

asMap() - インターフェース org.springframework.pulsar.cache.provider のメソッド。CacheProvider

キャッシュに格納されているエントリのビューをスレッドセーフマップとして返します。

asMap() - クラス org.springframework.pulsar.cache.provider.caffeine のメソッド。CaffeineCacheProvider

assertBeanFactory() - クラス org.springframework.pulsar.annotation のメソッド。AbstractPulsarAnnotationsBeanPostProcessor

autoStartup - Variable in class org.springframework.pulsar.core.AbstractPulsarMessageContainer

autoStartup() - Element in annotation interface org.springframework.pulsar.annotation.PulsarListener

このリスナーのコンテナーを自動的に起動するかどうか。

autoStartup() - Element in annotation interface org.springframework.pulsar.annotation.PulsarReader

autoStartup() - Element in annotation interface org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListener

このリスナーのコンテナーを自動的に起動するかどうか。