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
PulsarProducerFactorythat extends thedefault implementationby caching the created producers.Utility methods to help load configuration into aConsumerBuilder.Callback interface that can be implemented to customize theConsumerBuilderthat is used by thePulsarConsumerFactoryto create consumers.Default implementation ofExpressionResolverthat relies on theConfigurableBeanFactorycapabilities 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 definitionbuildersthat 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 toPulsarAdminto 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 aProducerinstance(s).PulsarReaderfactory 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 createPulsarTopicinstances.Callback interface that can be implemented to customize theReaderBuilderthat is used by thePulsarReaderFactoryto 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.