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
Publisher
when the callback is done.
-