Uses of Interface
org.springframework.pulsar.reactive.listener.ReactivePulsarMessageHandler

Packages that use ReactivePulsarMessageHandler

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

Uses of ReactivePulsarMessageHandler in org.springframework.pulsar.reactive.listener

Subinterfaces of ReactivePulsarMessageHandler in org.springframework.pulsar.reactive.listener

Modifier and Type	Interface	Description
interface	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>>).
interface	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>>>).

Methods in org.springframework.pulsar.reactive.listener that return ReactivePulsarMessageHandler

Modifier and Type	Method	Description
ReactivePulsarMessageHandler	ReactivePulsarContainerProperties.getMessageHandler()

Methods in org.springframework.pulsar.reactive.listener with parameters of type ReactivePulsarMessageHandler

Modifier and Type	Method	Description
void	ReactivePulsarContainerProperties.setMessageHandler(ReactivePulsarMessageHandler messageHandler)
void	DefaultReactivePulsarMessageListenerContainer.setupMessageHandler(ReactivePulsarMessageHandler messageHandler)
void	ReactivePulsarMessageListenerContainer.setupMessageHandler(ReactivePulsarMessageHandler messageListener)

Uses of ReactivePulsarMessageHandler in org.springframework.pulsar.reactive.listener.adapter

Classes in org.springframework.pulsar.reactive.listener.adapter that implement ReactivePulsarMessageHandler

Modifier and Type	Class	Description
class	PulsarReactiveOneByOneMessagingMessageListenerAdapter<V>	A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive individual messages.
class	PulsarReactiveStreamingMessagingMessageListenerAdapter<V>	A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive a flux of messages.