Interface PulsarMessageListenerContainer
- All Superinterfaces:
DisposableBean,Lifecycle,MessageListenerContainer,Phased,SmartLifecycle
- All Known Implementing Classes:
AbstractPulsarMessageListenerContainer,ConcurrentPulsarMessageListenerContainer,DefaultPulsarMessageListenerContainer
public sealed interface PulsarMessageListenerContainer
extends MessageListenerContainer
permits AbstractPulsarMessageListenerContainer<T>
Internal abstraction used by the framework representing a message listener container.
Not meant to be implemented externally.
- Author:
- Soby Chacko
-
Field Summary
Fields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE -
Method Summary
Modifier and TypeMethodDescriptiondefault PulsarContainerPropertiesvoidsetAckTimeoutRedeliveryBackoff(org.apache.pulsar.client.api.RedeliveryBackoff redeliveryBackoff) voidsetDeadLetterPolicy(org.apache.pulsar.client.api.DeadLetterPolicy deadLetterPolicy) voidsetNegativeAckRedeliveryBackoff(org.apache.pulsar.client.api.RedeliveryBackoff redeliveryBackoff) voidsetPulsarConsumerErrorHandler(PulsarConsumerErrorHandler pulsarConsumerErrorHandler) voidsetupMessageListener(Object messageListener) Methods inherited from interface org.springframework.pulsar.listener.MessageListenerContainer
destroy, setAutoStartupMethods inherited from interface org.springframework.context.SmartLifecycle
getPhase, isAutoStartup, stop
-
Method Details
-
setupMessageListener
-
getContainerProperties
-
setNegativeAckRedeliveryBackoff
void setNegativeAckRedeliveryBackoff(org.apache.pulsar.client.api.RedeliveryBackoff redeliveryBackoff) -
setAckTimeoutRedeliveryBackoff
void setAckTimeoutRedeliveryBackoff(org.apache.pulsar.client.api.RedeliveryBackoff redeliveryBackoff) -
setDeadLetterPolicy
void setDeadLetterPolicy(org.apache.pulsar.client.api.DeadLetterPolicy deadLetterPolicy) -
setPulsarConsumerErrorHandler
-