Interface ReactivePulsarMessageListenerContainer<T>
- Type Parameters:
T- message type.
- All Superinterfaces:
DisposableBean,Lifecycle,MessageListenerContainer,Phased,SmartLifecycle
- All Known Implementing Classes:
DefaultReactivePulsarMessageListenerContainer
public sealed interface ReactivePulsarMessageListenerContainer<T>
extends MessageListenerContainer
permits DefaultReactivePulsarMessageListenerContainer<T>
Internal abstraction used by the framework representing a reactive message listener
container. Not meant to be implemented externally.
- Author:
- Christophe Bornet
-
Field Summary
Fields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE -
Method Summary
Modifier and TypeMethodDescriptiondefault ReactivePulsarContainerProperties<T>voidsetConsumerCustomizer(ReactiveMessageConsumerBuilderCustomizer<T> consumerCustomizer) voidsetupMessageHandler(ReactivePulsarMessageHandler messageListener) Methods inherited from interface org.springframework.pulsar.listener.MessageListenerContainer
destroy, setAutoStartupMethods inherited from interface org.springframework.context.SmartLifecycle
getPhase, isAutoStartup, stop
-
Method Details
-
setupMessageHandler
-
getContainerProperties
-
setConsumerCustomizer
-