Package org.springframework.pulsar.reactive.listener

@NonNullApi @NonNullFields package org.springframework.pulsar.reactive.listener

Package containing listener components for receiving Pulsar messages.

Related Packages

Package	Description
org.springframework.pulsar.reactive.listener.adapter	Package containing listener components for receiving Pulsar messages.

Class	Description
DefaultReactivePulsarMessageListenerContainer<T>	Default implementation for ReactivePulsarMessageListenerContainer.
ReactivePulsarContainerProperties<T>	Contains runtime properties for a reactive listener container.
ReactivePulsarMessageHandler	Reactive message handler used by DefaultReactivePulsarMessageListenerContainer.
ReactivePulsarMessageListenerContainer<T>	Internal abstraction used by the framework representing a reactive message listener container.
ReactivePulsarOneByOneMessageHandler<T>	Message handler class with a ReactivePulsarOneByOneMessageHandler.received(org.apache.pulsar.client.api.Message<T>) method for use in ReactiveMessagePipelineBuilder.messageHandler(java.util.function.Function<org.apache.pulsar.client.api.Message<T>, org.reactivestreams.Publisher<java.lang.Void>>).
ReactivePulsarStreamingHandler<T>	Message handler class with a ReactivePulsarStreamingHandler.received(reactor.core.publisher.Flux<org.apache.pulsar.client.api.Message<T>>) method for use in 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>>>).