Interface ReactivePulsarOneByOneMessageHandler<T>
- Type Parameters:
T- message payload type
- All Superinterfaces:
ReactivePulsarMessageHandler
- All Known Implementing Classes:
PulsarReactiveOneByOneMessagingMessageListenerAdapter
public non-sealed interface ReactivePulsarOneByOneMessageHandler<T>
extends ReactivePulsarMessageHandler
Message handler class with a
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>>).- Author:
- Christophe Bornet
-
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.
-
Method Details
-
received
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.- Parameters:
message- the message received- Returns:
- a completed
Publisherwhen the callback is done.
-