Package org.springframework.pulsar.reactive.listener

Interface ReactivePulsarMessageHandler

All Known Subinterfaces:

ReactivePulsarOneByOneMessageHandler<T>, ReactivePulsarStreamingHandler<T>

All Known Implementing Classes:

PulsarReactiveOneByOneMessagingMessageListenerAdapter, PulsarReactiveStreamingMessagingMessageListenerAdapter

public sealed interface ReactivePulsarMessageHandler
permits ReactivePulsarOneByOneMessageHandler<T>, ReactivePulsarStreamingHandler<T>

Reactive message handler used by DefaultReactivePulsarMessageListenerContainer.

Author:

Christophe Bornet