パッケージ org.springframework.pulsar.reactive.listener
@NonNullApi @NonNullFields パッケージ org.springframework.pulsar.reactive.listener
Pulsar メッセージを受信するためのリスナーコンポーネントを含むパッケージ。
- クラス説明
ReactivePulsarMessageListenerContainerのデフォルト実装。リアクティブリスナーコンテナーの実行時プロパティが含まれます。DefaultReactivePulsarMessageListenerContainerによって使用されるリアクティブメッセージハンドラー。リアクティブメッセージリスナーコンテナーを表すフレームワークによって使用される内部抽象化。ReactiveMessagePipelineBuilder.messageHandler(java.util.function.Function<org.apache.pulsar.client.api.Message<T>, org.reactivestreams.Publisher<java.lang.Void>>)で使用するReactivePulsarOneByOneMessageHandler.received(org.apache.pulsar.client.api.Message<T>)メソッドを備えたメッセージハンドラークラス。ReactiveMessagePipelineBuilder.streamingMessageHandler(java.util.function.Function<reactor.core.publisher.Flux<org.apache.pulsar.client.api.Message<T>>, org.reactivestreams.Publisher<org.apache.pulsar.reactive.client.api.MessageResult<java.lang.Void>>>)で使用するReactivePulsarStreamingHandler.received(reactor.core.publisher.Flux<org.apache.pulsar.client.api.Message<T>>)メソッドを備えたメッセージハンドラークラス。