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 PulsarContainerPropertiesdefault voidpause()Pause this container before the next poll().default voidresume()Resume this container, if paused.voidsetAckTimeoutRedeliveryBackoff(org.apache.pulsar.client.api.RedeliveryBackoff redeliveryBackoff) voidsetConsumerCustomizer(ConsumerBuilderCustomizer<?> consumerBuilderCustomizer) Set a consumer customizer on this container.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
-
pause
default void pause()Pause this container before the next poll(). The next poll by the container will be disabled as long asresume()is not called. -
resume
default void resume()Resume this container, if paused. -
setConsumerCustomizer
Set a consumer customizer on this container.- Parameters:
consumerBuilderCustomizer-ConsumerBuilderCustomizer
-