Package org.springframework.pulsar.annotation
@NonNullApi
@NonNullFields
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
PulsarListener
annotations on any Spring-managed bean in the container.ADeferredImportSelector
implementation with the lowest order to importPulsarBootstrapConfiguration
as late as possible.AnImportBeanDefinitionRegistrar
class that registers aPulsarListenerAnnotationBeanPostProcessor
bean capable of processing Spring's @PulsarListener
annotation.Resolves theObjectMapper
to 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 withPulsarListener
to be invoked by a Pulsar message listener container created under the covers by aPulsarListenerContainerFactory
according 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 theConsumerBuilder
that is used to create the underlying Pulsar consumer used by aPulsarListener
to receive messages.Container annotation that aggregates severalPulsarListener
annotations.Specifies default topic and schema info for a message class.APayloadMethodArgumentResolver
that can properly decodePulsarNull
payloads into null.Bean post-processor that registers methods annotated withPulsarListener
to be invoked by a Pulsar message listener container created under the covers by aPulsarReaderContainerFactory
according 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 theReaderBuilder
that is used to create the underlying Pulsar reader used by a@PulsarReader
to receive messages.