Package org.springframework.pulsar.annotation
@NullMarked
package org.springframework.pulsar.annotation
Package containing annotations used by the framework.
-
ClassDescriptionBase class implementation for the various annotation post processors in Spring Pulsar.Enables detection of
PulsarListenerannotations on any Spring-managed bean in the container.ADeferredImportSelectorimplementation with the lowest order to importPulsarBootstrapConfigurationas late as possible.AnImportBeanDefinitionRegistrarclass that registers aPulsarListenerAnnotationBeanPostProcessorbean capable of processing Spring's @PulsarListenerannotation.Resolves theObjectMapperto use when serializing JSON header values.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 withPulsarListenerto be invoked by a Pulsar message listener container created under the covers by aPulsarListenerContainerFactoryaccording to the parameters of the annotation.Optional interface to be implemented by Spring managed bean willing to customize how Pulsar listener endpoints are configured.Callback interface that can be implemented by a bean to customize theConsumerBuilderthat is used to create the underlying Pulsar consumer used by aPulsarListenerto receive messages.Container annotation that aggregates severalPulsarListenerannotations.Specifies default topic and schema info for a message class.APayloadMethodArgumentResolverthat can properly decodePulsarNullpayloads into null.Bean post-processor that registers methods annotated withPulsarListenerto be invoked by a Pulsar message listener container created under the covers by aPulsarReaderContainerFactoryaccording to the parameters of the annotation.Optional interface to be implemented by Spring managed bean willing to customize how Pulsar listener endpoints are configured.Callback interface that can be implemented by a bean to customize theReaderBuilderthat is used to create the underlying Pulsar reader used by a@PulsarReaderto receive messages.