Package org.springframework.pulsar.reactive.listener

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 Type
    Method
    Description
    org.reactivestreams.Publisher<Void>
    received(org.apache.pulsar.client.api.Message<T> message)
    Callback passed to ReactiveMessagePipelineBuilder.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

      org.reactivestreams.Publisher<Void> received(org.apache.pulsar.client.api.Message<T> message)
      Callback passed to ReactiveMessagePipelineBuilder.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.