Package org.springframework.pulsar.listener

@NonNullApi @NonNullFields package org.springframework.pulsar.listener

Package containing listener components for receiving Pulsar messages.

Related Packages

Package	Description
org.springframework.pulsar	Package containing the Spring for Apache Pulsar framework classes.
org.springframework.pulsar.listener.adapter	Package containing components for adapting Pulsar messages to message listeners.

Class	Description
AbstractPulsarMessageListenerContainer<T>	Base implementation for the PulsarMessageListenerContainer.
AckMode	Enumeration for ack mode.
Acknowledgement	Contract for manual acknowledgment.
ConcurrentPulsarMessageListenerContainer<T>	Creates a concurrent execution context of DefaultPulsarMessageListenerContainer instances based on the concurrency.
DefaultPulsarConsumerErrorHandler<T>	Default implementation for PulsarConsumerErrorHandler.
DefaultPulsarMessageListenerContainer<T>	Default implementation for PulsarMessageListenerContainer.
MessageListenerContainer	Internal abstraction used by the framework representing a message listener container.
PulsarAcknowledgingMessageListener<T>	Message listener for manually acknowledging messages.
PulsarBatchAcknowledgingMessageListener<T>	Batch message listener that allows manual acknowledgment.
PulsarBatchListenerFailedException	Batch message listeners should throw this exception in the event of an error.
PulsarBatchMessageListener<T>	Batch message listener.
PulsarConsumerErrorHandler<T>	Contract for consumer error handling through the message listener container.
PulsarContainerProperties	Contains runtime properties for a listener container.
PulsarContainerProperties.TransactionSettings	Transaction related settings.
PulsarDeadLetterPublishingRecoverer<T>	PulsarMessageRecoverer implementation that is capable of recovering the message by publishing the failed record to a DLT - Dead Letter Topic.
PulsarListenerContainerRegistry	A registry for containers.
PulsarMessageListenerContainer	Internal abstraction used by the framework representing a message listener container.
PulsarMessageRecoverer<T>	Allows recovering a failed Pulsar message.
PulsarMessageRecovererFactory<T>	Factory interface for PulsarMessageRecoverer.
PulsarRecordMessageListener<T>	Base record MessageListener that simply extends from MessageListener.