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

Field Summary

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Method Summary

Modifier and Type	Method	Description
default PulsarContainerProperties	getContainerProperties()
default void	pause()	Pause this container before the next poll().
default void	resume()	Resume this container, if paused.
void	setAckTimeoutRedeliveryBackoff(org.apache.pulsar.client.api.RedeliveryBackoff redeliveryBackoff)
void	setConsumerCustomizer(ConsumerBuilderCustomizer<?> consumerBuilderCustomizer)	Set a consumer customizer on this container.
void	setDeadLetterPolicy(org.apache.pulsar.client.api.DeadLetterPolicy deadLetterPolicy)
void	setNegativeAckRedeliveryBackoff(org.apache.pulsar.client.api.RedeliveryBackoff redeliveryBackoff)
void	setPulsarConsumerErrorHandler(PulsarConsumerErrorHandler pulsarConsumerErrorHandler)
void	setupMessageListener(Object messageListener)

Methods inherited from interface org.springframework.context.Lifecycle

isRunning, start, stop

Methods inherited from interface org.springframework.pulsar.listener.MessageListenerContainer

destroy, setAutoStartup

Methods inherited from interface org.springframework.context.SmartLifecycle

getPhase, isAutoStartup, stop

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)

pause

default void pause()

Pause this container before the next poll(). The next poll by the container will be disabled as long as resume() is not called.

resume

default void resume()

Resume this container, if paused.

setConsumerCustomizer

void setConsumerCustomizer(ConsumerBuilderCustomizer<?> consumerBuilderCustomizer)

Set a consumer customizer on this container.

Parameters:

consumerBuilderCustomizer - ConsumerBuilderCustomizer