Interface ReactivePulsarStreamingHandler<T>
- Type Parameters:
T
- message payload type
- All Superinterfaces:
ReactivePulsarMessageHandler
- All Known Implementing Classes:
PulsarReactiveStreamingMessagingMessageListenerAdapter
Message handler class with a
received(reactor.core.publisher.Flux<org.apache.pulsar.client.api.Message<T>>)
method for use in
ReactiveMessagePipelineBuilder.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>>>)
.- Author:
- Christophe Bornet
-
Method Summary
Modifier and TypeMethodDescriptionorg.reactivestreams.Publisher<org.apache.pulsar.reactive.client.api.MessageResult<Void>>
Callback passed toReactiveMessagePipelineBuilder.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>>>)
that will be applied to the flux of received message.
-
Method Details
-
received
org.reactivestreams.Publisher<org.apache.pulsar.reactive.client.api.MessageResult<Void>> received(reactor.core.publisher.Flux<org.apache.pulsar.client.api.Message<T>> messages) Callback passed toReactiveMessagePipelineBuilder.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>>>)
that will be applied to the flux of received message.- Parameters:
messages
- the messages received- Returns:
- a completed
Publisher
when the callback is done.
-