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