Interface ReactivePulsarListenerEndpoint<T>
- Type Parameters:
T
- Message payload type.
- All Superinterfaces:
ListenerEndpoint<ReactivePulsarMessageListenerContainer<T>>
- All Known Implementing Classes:
AbstractReactivePulsarListenerEndpoint
,MethodReactivePulsarListenerEndpoint
,ReactivePulsarListenerEndpointAdapter
public interface ReactivePulsarListenerEndpoint<T>
extends ListenerEndpoint<ReactivePulsarMessageListenerContainer<T>>
Model for a Pulsar reactive listener endpoint. Can be used against a
ReactivePulsarListenerConfigurationSelector
to register endpoints
programmatically.- Author:
- Christophe Bornet, Chris Bono, Vedran Pavic
-
Method Summary
Methods inherited from interface org.springframework.pulsar.config.ListenerEndpoint
getAutoStartup, getConcurrency, getId, getSchemaType, getSubscriptionName, getSubscriptionType, getTopicPattern, getTopics, setupListenerContainer
-
Method Details
-
isFluxListener
default boolean isFluxListener() -
getUseKeyOrderedProcessing
-