Uses of Package
org.springframework.pulsar.reactive.listener
Packages that use org.springframework.pulsar.reactive.listener
Package
Description
Package containing Spring configuration classes for the framework.
Package containing listener components for receiving Pulsar messages.
Package containing listener components for receiving Pulsar messages.
-
Classes in org.springframework.pulsar.reactive.listener used by org.springframework.pulsar.reactive.configClassDescriptionDefault implementation for
ReactivePulsarMessageListenerContainer.Contains runtime properties for a reactive listener container.Internal abstraction used by the framework representing a reactive message listener container. -
Classes in org.springframework.pulsar.reactive.listener used by org.springframework.pulsar.reactive.listenerClassDescriptionContains runtime properties for a reactive listener container.Reactive message handler used by
DefaultReactivePulsarMessageListenerContainer.Internal abstraction used by the framework representing a reactive message listener container. -
Classes in org.springframework.pulsar.reactive.listener used by org.springframework.pulsar.reactive.listener.adapterClassDescriptionReactive message handler used by
DefaultReactivePulsarMessageListenerContainer.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>>>).