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>>>).