Package org.springframework.pulsar.reactive.listener
@NonNullApi
@NonNullFields
package org.springframework.pulsar.reactive.listener
Package containing listener components for receiving Pulsar messages.
-
ClassDescriptionDefault implementation for
ReactivePulsarMessageListenerContainer
.Contains runtime properties for a reactive listener container.Reactive message handler used byDefaultReactivePulsarMessageListenerContainer
.Internal abstraction used by the framework representing a reactive message listener container.Message handler class with aReactivePulsarOneByOneMessageHandler.received(org.apache.pulsar.client.api.Message<T>)
method for use inReactiveMessagePipelineBuilder.messageHandler(java.util.function.Function<org.apache.pulsar.client.api.Message<T>, org.reactivestreams.Publisher<java.lang.Void>>)
.Message handler class with aReactivePulsarStreamingHandler.received(reactor.core.publisher.Flux<org.apache.pulsar.client.api.Message<T>>)
method for use inReactiveMessagePipelineBuilder.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>>>)
.