Package org.springframework.pulsar.listener

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

  • Method Details

    • setupMessageListener

      void setupMessageListener(Object messageListener)

    • getContainerProperties

      default PulsarContainerProperties 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

      void setPulsarConsumerErrorHandler(PulsarConsumerErrorHandler pulsarConsumerErrorHandler)