Package org.springframework.pulsar.core
@NonNullApi
@NonNullFields
package org.springframework.pulsar.core
Package containing the core components of the framework.
-
ClassDescriptionBase class for the various container implementations.A
PulsarProducerFactory
that extends thedefault implementation
by caching the created producers.Utility methods to help load configuration into aConsumerBuilder
.Callback interface that can be implemented to customize theConsumerBuilder
that is used by thePulsarConsumerFactory
to create consumers.Default implementation ofExpressionResolver
that relies on theConfigurableBeanFactory
capabilities to resolve expressions.Default implementation forPulsarClientFactory
.Default implementation forPulsarConsumerFactory
.Default implementation ofPulsarProducerFactory
.Default implementation ofPulsarReaderFactory
.Default schema resolver capable of handling basic message types.Topic resolver that accepts custom type to topic mappings and uses the mappings during topic resolution.Strategy interface for resolving a value from a string expression.Factory to create schema definitionbuilders
that provide schema definitions that use custom object mappers when de/serializing objects.Reader implementation for reading objects from JSON using a customObjectMapper
.Writer implementation for writing objects as JSON using a customObjectMapper
.Deprecated, for removal: This API element is subject to removal in a future version.since 1.1.0 for removal in 1.2.0The interface to customize aProducerBuilder
.The interface to customize aPulsarAdminBuilder
.An administration class that delegates toPulsarAdmin
to create and manage topics defined in the application context.The Pulsar administration contract.The interface to customize aClientBuilder
.Pulsar client factory interface.Pulsar consumer factory interface.The basic Pulsar operations contract.Builder that can be used to configure and send a message.The strategy to create aProducer
instance(s).PulsarReader
factory interface.A template for executing high-level Pulsar operations.A callback for executing arbitrary operations on aPulsarTemplate
.Callback interface that can be implemented to customize aPulsarTemplate
.Represents a Pulsar topic.Builder class to createPulsarTopic
instances.Callback interface that can be implemented to customize theReaderBuilder
that is used by thePulsarReaderFactory
to create readers.Resolved<T>A resolved value or an exception if it could not be resolved.Resolves schema to use for message types.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.Resolves topics to use when producing or consuming.Common transaction settings for components.The interface to customize aTypedMessageBuilder
.