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