Package org.springframework.pulsar.listener
@NonNullApi
@NonNullFields
package org.springframework.pulsar.listener
Package containing listener components for receiving Pulsar messages.
-
ClassDescriptionBase implementation for the
PulsarMessageListenerContainer
.Enumeration for ack mode.Contract for manual acknowledgment.Creates a concurrent execution context ofDefaultPulsarMessageListenerContainer
instances based on theconcurrency
.Default implementation forPulsarConsumerErrorHandler
.Default implementation forPulsarMessageListenerContainer
.A registry for containers.Internal abstraction used by the framework representing a message listener container.Message listener for manually acknowledging messages.Batch message listener that allows manual acknowledgment.Batch message listeners should throw this exception in the event of an error.Batch message listener.Contract for consumer error handling through the message listener container.Contains runtime properties for a listener container.PulsarMessageRecoverer
implementation that is capable of recovering the message by publishing the failed record to a DLT - Dead Letter Topic.A registry for listener containers.Internal abstraction used by the framework representing a message listener container.Allows recovering a failed Pulsar message.Factory interface forPulsarMessageRecoverer
.Base record MessageListener that simply extends fromMessageListener
.