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
ConstructorsConstructorDescription -
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, isMultipleMessageTypeMethods 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:ReactivePulsarOneByOneMessageHandlerCallback 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:
receivedin interfaceReactivePulsarOneByOneMessageHandler<V>- Parameters:
record- the message received- Returns:
- a completed
Publisherwhen the callback is done.
-