Package org.springframework.pulsar.core

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

Package containing the core components of the framework.

Related Packages

Package	Description
org.springframework.pulsar	Package containing the Spring for Apache Pulsar framework classes.

Class	Description
AbstractPulsarMessageContainer	Base class for the various container implementations.
CachingPulsarProducerFactory<T>	A PulsarProducerFactory that extends the default implementation by caching the created producers.
ConsumerBuilderConfigurationUtil	Utility methods to help load configuration into a ConsumerBuilder.
ConsumerBuilderCustomizer<T>	Callback interface that can be implemented to customize the ConsumerBuilder that is used by the PulsarConsumerFactory to create consumers.
DefaultPulsarClientFactory	Default implementation for PulsarClientFactory.
DefaultPulsarConsumerFactory<T>	Default implementation for PulsarConsumerFactory.
DefaultPulsarProducerFactory<T>	Default implementation of PulsarProducerFactory.
DefaultPulsarReaderFactory<T>	Default implementation of PulsarReaderFactory.
DefaultSchemaResolver	Default schema resolver capable of handling basic message types.
DefaultTopicResolver	Topic resolver that accepts custom type to topic mappings and uses the mappings during topic resolution.
ProducerBuilderConfigurationUtil	Utility methods to help load configuration into a ProducerBuilder.
ProducerBuilderCustomizer<T>	The interface to customize a ProducerBuilder.
PulsarAdminBuilderCustomizer	The interface to customize a PulsarAdminBuilder.
PulsarAdministration	An administration class that delegates to PulsarAdmin to create and manage topics defined in the application context.
PulsarAdministrationOperations	The Pulsar administration contract.
PulsarClientBuilderCustomizer	The interface to customize a ClientBuilder.
PulsarClientFactory	Pulsar client factory interface.
PulsarConsumerFactory<T>	Pulsar consumer factory interface.
PulsarOperations<T>	The basic Pulsar operations contract.
PulsarOperations.SendMessageBuilder<T>	Builder that can be used to configure and send a message.
PulsarProducerFactory<T>	The strategy to create a Producer instance(s).
PulsarReaderFactory<T>	Pulsar Reader factory interface.
PulsarTemplate<T>	A template for executing high-level Pulsar operations.
PulsarTemplate.SendMessageBuilderImpl<T>
PulsarTopic	Model class for a Pulsar topic.
PulsarTopicBuilder	Builder class to create PulsarTopic instances.
ReaderBuilderCustomizer<T>	Callback interface that can be implemented to customize the ReaderBuilder that is used by the PulsarReaderFactory to create readers.
Resolved<T>	A resolved value or an exception if it could not be resolved.
SchemaResolver	Resolves schema to use for message types.
SchemaResolver.SchemaResolverCustomizer<T extends SchemaResolver>	Callback interface that can be implemented by beans wishing to customize the schema resolver before it is fully initialized, in particular to tune its configuration.
TopicResolver	Resolves topics to use when producing or consuming.
TypedMessageBuilderCustomizer<T>	The interface to customize a TypedMessageBuilder.