Class PulsarReactiveOneByOneMessagingMessageListenerAdapter<V>
java.lang.Object
org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter<V>
org.springframework.pulsar.reactive.listener.adapter.PulsarReactiveMessagingMessageListenerAdapter<V>
org.springframework.pulsar.reactive.listener.adapter.PulsarReactiveOneByOneMessagingMessageListenerAdapter<V>
- Type Parameters:
V
- payload type.
- All Implemented Interfaces:
ReactivePulsarMessageHandler
,ReactivePulsarOneByOneMessageHandler<V>
public class PulsarReactiveOneByOneMessagingMessageListenerAdapter<V>
extends PulsarReactiveMessagingMessageListenerAdapter<V>
implements ReactivePulsarOneByOneMessageHandler<V>
A
MessageListener
adapter that invokes a
configurable HandlerAdapter
; used when the factory is configured for the
listener to receive individual messages.- Author:
- Christophe Bornet, Soby Chacko
-
Field Summary
Fields inherited from class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter
logger
-
Constructor Summary
ConstructorDescription -
Method Summary
Modifier and TypeMethodDescriptionorg.reactivestreams.Publisher<Void>
Callback passed toReactiveMessagePipelineBuilder.messageHandler(java.util.function.Function<org.apache.pulsar.client.api.Message<T>, org.reactivestreams.Publisher<java.lang.Void>>)
that will be called for each received message.Methods inherited from class org.springframework.pulsar.reactive.listener.adapter.PulsarReactiveMessagingMessageListenerAdapter
isFlux, isMultipleMessageType
Methods inherited from class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter
determineInferredType, getMessageConverter, getType, invokeHandler, isConsumerRecords, isHeaderFound, isMessageList, isPulsarMessageList, isSimpleExtraction, isSpringMessage, isSpringMessageFlux, parameterIsType, setBeanResolver, setFallbackType, setHandlerMethod, setMessageConverter, setMessagingConverter, toMessagingMessage, toMessagingMessageFromReader
-
Constructor Details
-
PulsarReactiveOneByOneMessagingMessageListenerAdapter
-
-
Method Details
-
received
Description copied from interface:ReactivePulsarOneByOneMessageHandler
Callback passed toReactiveMessagePipelineBuilder.messageHandler(java.util.function.Function<org.apache.pulsar.client.api.Message<T>, org.reactivestreams.Publisher<java.lang.Void>>)
that will be called for each received message.- Specified by:
received
in interfaceReactivePulsarOneByOneMessageHandler<V>
- Parameters:
record
- the message received- Returns:
- a completed
Publisher
when the callback is done.
-