Uses of Interface
org.springframework.pulsar.reactive.listener.ReactivePulsarMessageHandler
Packages that use ReactivePulsarMessageHandler
Package
Description
Package containing listener components for receiving Pulsar messages.
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.listenerModifier and TypeInterfaceDescriptioninterfaceMessage 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>>).interfaceMessage 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>>>).Methods in org.springframework.pulsar.reactive.listener that return ReactivePulsarMessageHandlerMethods in org.springframework.pulsar.reactive.listener with parameters of type ReactivePulsarMessageHandlerModifier and TypeMethodDescriptionvoidReactivePulsarContainerProperties.setMessageHandler(ReactivePulsarMessageHandler messageHandler) voidDefaultReactivePulsarMessageListenerContainer.setupMessageHandler(ReactivePulsarMessageHandler messageHandler) voidReactivePulsarMessageListenerContainer.setupMessageHandler(ReactivePulsarMessageHandler messageListener) -
Uses of ReactivePulsarMessageHandler in org.springframework.pulsar.reactive.listener.adapter
Classes in org.springframework.pulsar.reactive.listener.adapter that implement ReactivePulsarMessageHandlerModifier and TypeClassDescriptionclassAMessageListeneradapter that invokes a configurableHandlerAdapter; used when the factory is configured for the listener to receive individual messages.classAMessageListeneradapter that invokes a configurableHandlerAdapter; used when the factory is configured for the listener to receive a flux of messages.