Package org.springframework.pulsar.core

@NullMarked 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.
DefaultExpressionResolver	Default implementation of ExpressionResolver that relies on the ConfigurableBeanFactory capabilities to resolve expressions.
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.
ExpressionResolver	Strategy interface for resolving a value from a string expression.
JSONSchemaUtil	Factory to create schema definition builders that provide schema definitions that use custom object mappers when de/serializing objects.
JSONSchemaUtil.CustomJacksonJsonReader<T>	Reader implementation for reading objects from JSON using a custom ObjectMapper.
JSONSchemaUtil.CustomJacksonJsonWriter<T>	Writer implementation for writing objects as JSON using a custom ObjectMapper.
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>
PulsarTemplate.TemplateCallback<T,R>	A callback for executing arbitrary operations on a PulsarTemplate.
PulsarTemplateCustomizer<T>	Callback interface that can be implemented to customize a PulsarTemplate.
PulsarTopic	Represents 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.
TransactionProperties	Common transaction settings for components.
TypedMessageBuilderCustomizer<T>	The interface to customize a TypedMessageBuilder.