Package org.springframework.pulsar.reactive.listener

Interface ReactivePulsarStreamingHandler<T>

Type Parameters:
T - message payload type
All Superinterfaces:
ReactivePulsarMessageHandler
All Known Implementing Classes:
PulsarReactiveStreamingMessagingMessageListenerAdapter
public non-sealed interface ReactivePulsarStreamingHandler<T> extends ReactivePulsarMessageHandler
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 Type
    Method
    Description
    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 to 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>>>) 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 to 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>>>) that will be applied to the flux of received message.
      Parameters:
      messages - the messages received
      Returns:
      a completed Publisher when the callback is done.