All Classes and Interfaces
Class
Description
Base
PulsarListenerContainerFactory implementation.Base implementation for
PulsarListenerEndpoint.Base implementation for the
PulsarMessageListenerContainer.Enumeration for ack mode.
Contract for manual acknowledgment.
A
PulsarProducerFactory that extends the default implementation by caching the created producers.Concrete implementation for
PulsarListenerContainerFactory.Creates a concurrent execution context of
DefaultPulsarMessageListenerContainer
instances based on the concurrency.Event to publish when the consumer is failed to start.
Event to publish when the consumer is started.
Event to publish while the consumer is starting.
Default implementation for
PulsarConsumerErrorHandler.Default implementation for
PulsarConsumerFactory.Default implementation for
PulsarMessageListenerContainer.Default implementation of
PulsarProducerFactory.Delegates to an
InvocableHandlerMethod based on the message payload type.Enables detection of
PulsarListener annotations on any Spring-managed bean in
the container.Handler method for endpoints.
A wrapper for either an
InvocableHandlerMethod or
DelegatingInvocableHandler.The result of a method invocation.
Chained utility methods to simplify some Java repetitive code.
Pulsar specific message converter.
A
PulsarListenerEndpoint providing the method to invoke to process an incoming
message for this endpoint.The interface to customize a
ProducerBuilder.Message listener for manually acknowledging messages.
An administration class that delegates to
PulsarAdmin to create and manage
topics defined in the application context.The Pulsar administration contract.
Configuration for Pulsar annotation-driven support.
Auto-configuration for Apache Pulsar.Batch message listener that allows manual acknowledgment.
Batch message listeners should throw this exception in the event of an error.
Pulsar batch message converter strategy.
Batch message listener.
Batch records message converter.
A
MessageListener adapter that
invokes a configurable HandlerAdapter; used when the factory is configured for
the listener to receive batches of messages.An
ImportBeanDefinitionRegistrar class that registers a
PulsarListenerAnnotationBeanPostProcessor bean capable of processing
Spring's @PulsarListener annotation.Configuration for the Pulsar client.
FactoryBean implementation for the PulsarClient.Contract for consumer error handling through the message listener container.
Pulsar consumer factory interface.
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.Base class for events.
Spring Pulsar specific
NestedRuntimeException implementation.Annotation that marks a method to be the target of a Pulsar message listener on the
specified topics.
Bean post-processor that registers methods annotated with
PulsarListener to be
invoked by a Pulsar message listener container created under the covers by a
PulsarListenerContainerFactory according to the parameters of the annotation.Constants for bean names that need to be accessed in multiple places by name.
A
DeferredImportSelector implementation with the lowest order to import a
PulsarBootstrapConfiguration as late as possible.Optional interface to be implemented by Spring managed bean willing to customize how
Pulsar listener endpoints are configured.
Factory for Pulsar message listener containers.
A registry for listener containers.
Model for a Pulsar listener endpoint.
Adapter to avoid having to implement all methods.
Helper bean for registering
PulsarListenerEndpoint with a
PulsarListenerEndpointRegistry.Creates the necessary
PulsarMessageListenerContainer instances for the
registered endpoints.Container annotation that aggregates several
PulsarListener annotations.Internal abstraction used by the framework representing a message listener container.
Allows recovering a failed Pulsar message.
Factory interface for
PulsarMessageRecoverer.A Messaging
MessageConverter implementation
for a message listener that receives individual messages.An abstract
MessageListener adapter providing the
necessary infrastructure to extract the payload from a Pulsar message.The basic Pulsar operations contract.
Builder that can be used to configure and send a message.
The strategy to create a
Producer instance(s).Configuration properties for Spring for Apache Pulsar.
Pulsar specific record converter strategy.
Base record MessageListener that simply extends from
MessageListener.A
MessageListener adapter that invokes a configurable
HandlerAdapter; used when the factory is configured for the listener to receive
individual messages.A thread-safe template for executing high-level Pulsar operations.
Model class for a Pulsar topic.
Builder class to create
PulsarTopic instances.Utility class for Pulsar schema inference.
The interface to customize a
TypedMessageBuilder.Utility class to map Pulsar auth parameters to well-known keys.