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>
void
setConsumerCustomizer
(ReactiveMessageConsumerBuilderCustomizer<T> consumerCustomizer) void
setupMessageHandler
(ReactivePulsarMessageHandler messageListener) Methods inherited from interface org.springframework.pulsar.listener.MessageListenerContainer
destroy, setAutoStartup
Methods inherited from interface org.springframework.context.SmartLifecycle
getPhase, isAutoStartup, stop
-
Method Details
-
setupMessageHandler
-
getContainerProperties
-
setConsumerCustomizer
-