Hierarchy For All Packages

Package Hierarchies:

• org.springframework.pulsar,
• org.springframework.pulsar.annotation,
• org.springframework.pulsar.aot,
• org.springframework.pulsar.cache.provider,
• org.springframework.pulsar.cache.provider.caffeine,
• org.springframework.pulsar.config,
• org.springframework.pulsar.core,
• org.springframework.pulsar.event,
• org.springframework.pulsar.function,
• org.springframework.pulsar.listener,
• org.springframework.pulsar.listener.adapter,
• org.springframework.pulsar.observation,
• org.springframework.pulsar.reactive.aot,
• org.springframework.pulsar.reactive.config,
• org.springframework.pulsar.reactive.config.annotation,
• org.springframework.pulsar.reactive.core,
• org.springframework.pulsar.reactive.listener,
• org.springframework.pulsar.reactive.listener.adapter,
• org.springframework.pulsar.reactive.support,
• org.springframework.pulsar.reader,
• org.springframework.pulsar.support,
• org.springframework.pulsar.support.converter,
• org.springframework.pulsar.support.header,
• org.springframework.pulsar.transaction

Class Hierarchy

• java.lang.Object
  • org.springframework.transaction.support.AbstractPlatformTransactionManager (implements org.springframework.transaction.ConfigurableTransactionManager, org.springframework.transaction.PlatformTransactionManager, java.io.Serializable)
    • org.springframework.pulsar.transaction.PulsarTransactionManager (implements org.springframework.pulsar.transaction.PulsarAwareTransactionManager)
  • org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor (implements org.springframework.context.ApplicationContextAware, org.springframework.beans.factory.config.BeanPostProcessor, org.springframework.beans.factory.InitializingBean, org.springframework.core.Ordered)
    • org.springframework.pulsar.annotation.PulsarListenerAnnotationBeanPostProcessor<V> (implements org.springframework.beans.factory.SmartInitializingSingleton)
    • org.springframework.pulsar.annotation.PulsarReaderAnnotationBeanPostProcessor<V> (implements org.springframework.beans.factory.SmartInitializingSingleton)
    • org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListenerAnnotationBeanPostProcessor<V> (implements org.springframework.beans.factory.SmartInitializingSingleton)
  • org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor.ListenerScope (implements org.springframework.beans.factory.config.Scope)
  • org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor.PulsarHandlerMethodFactoryAdapter (implements org.springframework.messaging.handler.annotation.support.MessageHandlerMethodFactory)
  • org.springframework.pulsar.support.header.AbstractPulsarHeaderMapper<ToPulsarHeadersContextType,ToSpringHeadersContextType> (implements org.springframework.pulsar.support.header.PulsarHeaderMapper)
    • org.springframework.pulsar.support.header.JsonPulsarHeaderMapper
    • org.springframework.pulsar.support.header.ToStringPulsarHeaderMapper
  • org.springframework.pulsar.config.AbstractPulsarListenerContainerFactory<C,T> (implements org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationEventPublisherAware, org.springframework.pulsar.config.PulsarListenerContainerFactory)
    • org.springframework.pulsar.config.ConcurrentPulsarListenerContainerFactory<T>
  • org.springframework.pulsar.config.AbstractPulsarListenerEndpoint<K> (implements org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, org.springframework.pulsar.config.PulsarListenerEndpoint)
    • org.springframework.pulsar.config.MethodPulsarListenerEndpoint<V>
  • org.springframework.pulsar.core.AbstractPulsarMessageContainer (implements org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationEventPublisherAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.context.SmartLifecycle)
    • org.springframework.pulsar.listener.AbstractPulsarMessageListenerContainer<T> (implements org.springframework.pulsar.listener.PulsarMessageListenerContainer)
      • org.springframework.pulsar.listener.ConcurrentPulsarMessageListenerContainer<T>
      • org.springframework.pulsar.listener.DefaultPulsarMessageListenerContainer<T>
    • org.springframework.pulsar.reader.AbstractPulsarMessageReaderContainer<T> (implements org.springframework.pulsar.reader.PulsarMessageReaderContainer)
      • org.springframework.pulsar.reader.DefaultPulsarMessageReaderContainer<T>
  • org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter<V>
    • org.springframework.pulsar.listener.adapter.PulsarBatchMessagesToSpringMessageListenerAdapter<V> (implements org.springframework.pulsar.listener.PulsarBatchAcknowledgingMessageListener<T>)
    • org.springframework.pulsar.reactive.listener.adapter.PulsarReactiveMessagingMessageListenerAdapter<V>
      • org.springframework.pulsar.reactive.listener.adapter.PulsarReactiveOneByOneMessagingMessageListenerAdapter<V> (implements org.springframework.pulsar.reactive.listener.ReactivePulsarOneByOneMessageHandler<T>)
      • org.springframework.pulsar.reactive.listener.adapter.PulsarReactiveStreamingMessagingMessageListenerAdapter<V> (implements org.springframework.pulsar.reactive.listener.ReactivePulsarStreamingHandler<T>)
    • org.springframework.pulsar.listener.adapter.PulsarRecordMessageToSpringMessageListenerAdapter<V> (implements org.springframework.pulsar.listener.PulsarAcknowledgingMessageListener<T>)
    • org.springframework.pulsar.listener.adapter.PulsarRecordMessageToSpringMessageReaderAdapter<V> (implements org.apache.pulsar.client.api.ReaderListener<T>)
  • org.springframework.pulsar.config.AbstractPulsarReaderContainerFactory<C,T> (implements org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationEventPublisherAware, org.springframework.pulsar.config.PulsarReaderContainerFactory)
    • org.springframework.pulsar.config.DefaultPulsarReaderContainerFactory<T>
  • org.springframework.pulsar.config.AbstractPulsarReaderEndpoint<K> (implements org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, org.springframework.pulsar.config.PulsarReaderEndpoint<C>)
    • org.springframework.pulsar.config.MethodPulsarReaderEndpoint<V>
  • org.springframework.pulsar.reactive.config.AbstractReactivePulsarListenerEndpoint<T> (implements org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, org.springframework.pulsar.reactive.config.ReactivePulsarListenerEndpoint<T>)
    • org.springframework.pulsar.reactive.config.MethodReactivePulsarListenerEndpoint<V>
  • org.springframework.pulsar.cache.provider.caffeine.CaffeineCacheProvider<K,V> (implements org.springframework.pulsar.cache.provider.CacheProvider<K,V>)
  • org.springframework.pulsar.cache.provider.caffeine.CaffeineCacheProviderFactory<K,V> (implements org.springframework.pulsar.cache.provider.CacheProviderFactory<K,V>)
  • org.springframework.pulsar.core.ConsumerBuilderConfigurationUtil
  • org.springframework.pulsar.core.DefaultExpressionResolver (implements org.springframework.pulsar.core.ExpressionResolver)
  • org.springframework.pulsar.core.DefaultPulsarClientFactory (implements org.springframework.context.EnvironmentAware, org.springframework.pulsar.core.PulsarClientFactory)
  • org.springframework.pulsar.listener.DefaultPulsarConsumerErrorHandler<T> (implements org.springframework.pulsar.listener.PulsarConsumerErrorHandler<T>)
  • org.springframework.pulsar.core.DefaultPulsarConsumerFactory<T> (implements org.springframework.pulsar.core.PulsarConsumerFactory<T>)
  • org.springframework.pulsar.observation.DefaultPulsarListenerObservationConvention (implements org.springframework.pulsar.observation.PulsarListenerObservationConvention)
  • org.springframework.pulsar.core.DefaultPulsarProducerFactory<T> (implements org.springframework.pulsar.core.PulsarProducerFactory<T>)
    • org.springframework.pulsar.core.CachingPulsarProducerFactory<T>
  • org.springframework.pulsar.core.DefaultPulsarReaderFactory<T> (implements org.springframework.pulsar.core.PulsarReaderFactory<T>)
  • org.springframework.pulsar.observation.DefaultPulsarTemplateObservationConvention (implements org.springframework.pulsar.observation.PulsarTemplateObservationConvention)
  • org.springframework.pulsar.reactive.core.DefaultReactivePulsarConsumerFactory<T> (implements org.springframework.pulsar.reactive.core.ReactivePulsarConsumerFactory<T>)
  • org.springframework.pulsar.reactive.config.DefaultReactivePulsarListenerContainerFactory<T> (implements org.springframework.pulsar.reactive.config.ReactivePulsarListenerContainerFactory<T>)
  • org.springframework.pulsar.reactive.listener.DefaultReactivePulsarMessageListenerContainer<T> (implements org.springframework.pulsar.reactive.listener.ReactivePulsarMessageListenerContainer<T>)
  • org.springframework.pulsar.reactive.core.DefaultReactivePulsarReaderFactory<T> (implements org.springframework.pulsar.reactive.core.ReactivePulsarReaderFactory<T>)
  • org.springframework.pulsar.reactive.core.DefaultReactivePulsarSenderFactory<T> (implements org.springframework.pulsar.reactive.core.ReactivePulsarSenderFactory<T>)
  • org.springframework.pulsar.reactive.core.DefaultReactivePulsarSenderFactory.Builder<T>
  • org.springframework.pulsar.core.DefaultSchemaResolver (implements org.springframework.pulsar.core.SchemaResolver)
  • org.springframework.pulsar.core.DefaultTopicResolver (implements org.springframework.beans.factory.BeanFactoryAware, org.springframework.pulsar.core.TopicResolver)
  • org.springframework.pulsar.listener.adapter.DelegatingInvocableHandler
  • java.util.EventObject (implements java.io.Serializable)
    • org.springframework.context.ApplicationEvent
      • org.springframework.pulsar.event.PulsarEvent
        • org.springframework.pulsar.event.ConsumerFailedToStartEvent
        • org.springframework.pulsar.event.ConsumerStartedEvent
        • org.springframework.pulsar.event.ConsumerStartingEvent
        • org.springframework.pulsar.event.ReaderFailedToStartEvent
        • org.springframework.pulsar.event.ReaderStartedEvent
        • org.springframework.pulsar.event.ReaderStartingEvent
  • org.springframework.pulsar.config.GenericListenerEndpointRegistry<C,E> (implements org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<E>, org.springframework.beans.factory.DisposableBean, org.springframework.pulsar.listener.PulsarListenerContainerRegistry, org.springframework.context.SmartLifecycle)
    • org.springframework.pulsar.config.PulsarListenerEndpointRegistry
    • org.springframework.pulsar.reactive.config.ReactivePulsarListenerEndpointRegistry<T>
  • org.springframework.pulsar.config.GenericReaderEndpointRegistry<C,E> (implements org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<E>, org.springframework.beans.factory.DisposableBean, org.springframework.pulsar.reader.PulsarReaderContainerRegistry, org.springframework.context.SmartLifecycle)
    • org.springframework.pulsar.config.PulsarReaderEndpointRegistry
  • org.springframework.pulsar.listener.adapter.HandlerAdapter
  • org.springframework.pulsar.listener.adapter.InvocationResult
  • org.springframework.pulsar.support.header.JacksonUtils
  • org.springframework.pulsar.support.JavaUtils
  • org.springframework.pulsar.support.header.JsonPulsarHeaderMapper.JsonPulsarHeaderMapperBuilder
  • org.springframework.pulsar.reactive.support.MessageUtils
  • io.micrometer.observation.Observation.Context (implements io.micrometer.observation.Observation.ContextView)
    • io.micrometer.observation.transport.ReceiverContext<C>
      • org.springframework.pulsar.observation.PulsarMessageReceiverContext
    • io.micrometer.observation.transport.SenderContext<C>
      • org.springframework.pulsar.observation.PulsarMessageSenderContext
  • org.springframework.messaging.handler.annotation.support.PayloadMethodArgumentResolver (implements org.springframework.messaging.handler.invocation.HandlerMethodArgumentResolver)
    • org.springframework.pulsar.annotation.PulsarNullAwarePayloadArgumentResolver
  • org.springframework.pulsar.core.ProducerBuilderConfigurationUtil
  • org.springframework.pulsar.core.PulsarAdministration (implements org.springframework.context.ApplicationContextAware, org.springframework.pulsar.core.PulsarAdministrationOperations, org.springframework.beans.factory.SmartInitializingSingleton)
  • org.springframework.pulsar.annotation.PulsarAnnotationsConfigurationSelector (implements org.springframework.context.annotation.DeferredImportSelector)
  • org.springframework.pulsar.config.PulsarAnnotationSupportBeanNames
  • org.springframework.pulsar.annotation.PulsarBootstrapConfiguration (implements org.springframework.context.annotation.ImportBeanDefinitionRegistrar)
  • org.springframework.pulsar.listener.PulsarContainerProperties
  • org.springframework.pulsar.listener.PulsarDeadLetterPublishingRecoverer<T> (implements org.springframework.pulsar.listener.PulsarMessageRecovererFactory<T>)
  • org.springframework.pulsar.function.PulsarFunctionAdministration (implements org.springframework.context.SmartLifecycle)
  • org.springframework.pulsar.support.header.PulsarHeaderMatcher.NeverMatch (implements org.springframework.pulsar.support.header.PulsarHeaderMatcher)
  • org.springframework.pulsar.support.header.PulsarHeaderMatcher.PatternMatch (implements org.springframework.pulsar.support.header.PulsarHeaderMatcher)
  • org.springframework.pulsar.support.PulsarHeaders
  • org.springframework.pulsar.config.PulsarListenerEndpointAdapter (implements org.springframework.pulsar.config.PulsarListenerEndpoint)
  • org.springframework.pulsar.config.PulsarListenerEndpointRegistrar (implements org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean)
  • org.springframework.pulsar.observation.PulsarMessageSenderContext.MessageHolder
  • org.springframework.pulsar.support.PulsarNull
  • org.springframework.pulsar.reader.PulsarReaderContainerProperties
  • org.springframework.pulsar.config.PulsarReaderEndpointRegistrar (implements org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean)
  • org.springframework.pulsar.support.converter.PulsarRecordMessageConverter<V> (implements org.springframework.pulsar.support.converter.PulsarMessageConverter<T>)
  • org.springframework.pulsar.aot.PulsarRuntimeHints (implements org.springframework.aot.hint.RuntimeHintsRegistrar)
  • org.springframework.pulsar.core.PulsarTemplate<T> (implements org.springframework.context.ApplicationContextAware, org.springframework.beans.factory.BeanNameAware, org.springframework.pulsar.core.PulsarOperations<T>, org.springframework.beans.factory.SmartInitializingSingleton)
  • org.springframework.pulsar.core.PulsarTemplate.SendMessageBuilderImpl<T> (implements org.springframework.pulsar.core.PulsarOperations.SendMessageBuilder<T>)
  • org.springframework.pulsar.core.PulsarTopicBuilder
  • org.springframework.pulsar.transaction.PulsarTransactionUtils
  • org.springframework.pulsar.reactive.config.annotation.ReactivePulsarBootstrapConfiguration (implements org.springframework.context.annotation.ImportBeanDefinitionRegistrar)
  • org.springframework.pulsar.reactive.listener.ReactivePulsarContainerProperties<T>
  • org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListenerConfigurationSelector (implements org.springframework.context.annotation.DeferredImportSelector)
  • org.springframework.pulsar.reactive.config.ReactivePulsarListenerEndpointAdapter<T> (implements org.springframework.pulsar.reactive.config.ReactivePulsarListenerEndpoint<T>)
  • org.springframework.pulsar.reactive.aot.ReactivePulsarRuntimeHints (implements org.springframework.aot.hint.RuntimeHintsRegistrar)
  • org.springframework.pulsar.reactive.core.ReactivePulsarTemplate<T> (implements org.springframework.pulsar.reactive.core.ReactivePulsarOperations<T>)
  • java.lang.Record
    • org.springframework.pulsar.support.header.JsonPulsarHeaderMapper.NonTrustedHeaderType
    • org.springframework.pulsar.support.header.JsonPulsarHeaderMapper.ToPulsarHeadersContext
    • org.springframework.pulsar.support.header.JsonPulsarHeaderMapper.ToSpringHeadersContext
    • org.springframework.pulsar.function.PulsarFunction (implements org.springframework.pulsar.function.PulsarFunctionOperations<T>)
    • org.springframework.pulsar.function.PulsarSink (implements org.springframework.pulsar.function.PulsarFunctionOperations<T>)
    • org.springframework.pulsar.function.PulsarSource (implements org.springframework.pulsar.function.PulsarFunctionOperations<T>)
    • org.springframework.pulsar.core.PulsarTopic
  • org.springframework.pulsar.core.Resolved<T>
  • org.springframework.transaction.support.ResourceHolderSupport (implements org.springframework.transaction.support.ResourceHolder)
    • org.springframework.pulsar.transaction.PulsarResourceHolder
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • org.springframework.core.NestedRuntimeException
          • org.springframework.pulsar.PulsarException
            • org.springframework.pulsar.listener.PulsarBatchListenerFailedException
            • org.springframework.pulsar.function.PulsarFunctionAdministration.PulsarFunctionException
  • org.springframework.pulsar.core.TransactionProperties
    • org.springframework.pulsar.listener.PulsarContainerProperties.TransactionSettings

Interface Hierarchy

• org.springframework.pulsar.listener.Acknowledgement
• org.springframework.pulsar.cache.provider.CacheProvider<K,V>
• org.springframework.pulsar.cache.provider.CacheProviderFactory<K,V>
• org.springframework.pulsar.cache.provider.CacheProviderFactory.EvictionListener<K,V>
• org.springframework.pulsar.config.ConcurrentPulsarListenerContainerFactoryCustomizer<T>
• org.springframework.pulsar.core.ConsumerBuilderCustomizer<T>
• org.springframework.beans.factory.DisposableBean
  • org.springframework.pulsar.listener.MessageListenerContainer (also extends org.springframework.context.SmartLifecycle)
    • org.springframework.pulsar.listener.PulsarMessageListenerContainer
    • org.springframework.pulsar.reactive.listener.ReactivePulsarMessageListenerContainer<T>
  • org.springframework.pulsar.reader.PulsarMessageReaderContainer (also extends org.springframework.context.SmartLifecycle)
• org.springframework.pulsar.core.ExpressionResolver
• io.micrometer.observation.KeyValuesConvention
  • io.micrometer.observation.ObservationConvention<T>
    • org.springframework.pulsar.observation.PulsarListenerObservationConvention
    • org.springframework.pulsar.observation.PulsarTemplateObservationConvention
• org.springframework.context.Lifecycle
  • org.springframework.context.SmartLifecycle (also extends org.springframework.context.Phased)
    • org.springframework.pulsar.listener.MessageListenerContainer (also extends org.springframework.beans.factory.DisposableBean)
      • org.springframework.pulsar.listener.PulsarMessageListenerContainer
      • org.springframework.pulsar.reactive.listener.ReactivePulsarMessageListenerContainer<T>
    • org.springframework.pulsar.reader.PulsarMessageReaderContainer (also extends org.springframework.beans.factory.DisposableBean)
• org.springframework.pulsar.config.ListenerContainerFactory<C,E>
  • org.springframework.pulsar.config.PulsarListenerContainerFactory
  • org.springframework.pulsar.reactive.config.ReactivePulsarListenerContainerFactory<T>
• org.springframework.pulsar.config.ListenerEndpoint<C>
  • org.springframework.pulsar.config.PulsarListenerEndpoint
  • org.springframework.pulsar.reactive.config.ReactivePulsarListenerEndpoint<T>
• org.springframework.pulsar.support.MessageConverter
  • org.springframework.pulsar.support.converter.PulsarMessageConverter<T>
• org.springframework.pulsar.reactive.core.MessageSpecBuilderCustomizer<T>
• org.springframework.context.Phased
  • org.springframework.context.SmartLifecycle (also extends org.springframework.context.Lifecycle)
    • org.springframework.pulsar.listener.MessageListenerContainer (also extends org.springframework.beans.factory.DisposableBean)
      • org.springframework.pulsar.listener.PulsarMessageListenerContainer
      • org.springframework.pulsar.reactive.listener.ReactivePulsarMessageListenerContainer<T>
    • org.springframework.pulsar.reader.PulsarMessageReaderContainer (also extends org.springframework.beans.factory.DisposableBean)
• org.springframework.pulsar.core.ProducerBuilderCustomizer<T>
• org.springframework.pulsar.core.PulsarAdminBuilderCustomizer
• org.springframework.pulsar.core.PulsarAdministrationOperations
• org.springframework.pulsar.core.PulsarClientBuilderCustomizer
• org.springframework.pulsar.core.PulsarClientFactory
• org.springframework.pulsar.listener.PulsarConsumerErrorHandler<T>
• org.springframework.pulsar.core.PulsarConsumerFactory<T>
• org.springframework.pulsar.function.PulsarFunctionOperations<T>
• org.springframework.pulsar.support.header.PulsarHeaderMapper
• org.springframework.pulsar.support.header.PulsarHeaderMatcher
• org.springframework.pulsar.annotation.PulsarListenerConfigurer
• org.springframework.pulsar.annotation.PulsarListenerConsumerBuilderCustomizer<T>
• org.springframework.pulsar.listener.PulsarListenerContainerRegistry
• org.springframework.pulsar.listener.PulsarMessageRecoverer<T>
• org.springframework.pulsar.listener.PulsarMessageRecovererFactory<T>
• org.springframework.pulsar.core.PulsarOperations<T>
• org.springframework.pulsar.core.PulsarOperations.SendMessageBuilder<T>
• org.springframework.pulsar.core.PulsarProducerFactory<T>
• org.springframework.pulsar.annotation.PulsarReaderConfigurer
• org.springframework.pulsar.reader.PulsarReaderContainerRegistry
• org.springframework.pulsar.config.PulsarReaderEndpoint<C>
• org.springframework.pulsar.core.PulsarReaderFactory<T>
• org.springframework.pulsar.annotation.PulsarReaderReaderBuilderCustomizer<T>
• org.springframework.pulsar.core.PulsarTemplate.TemplateCallback<T,R>
• org.springframework.pulsar.core.PulsarTemplateCustomizer<T>
• org.springframework.pulsar.reactive.core.ReactiveMessageConsumerBuilderCustomizer<T>
• org.springframework.pulsar.reactive.core.ReactiveMessageReaderBuilderCustomizer<T>
• org.springframework.pulsar.reactive.core.ReactiveMessageSenderBuilderCustomizer<T>
• org.springframework.pulsar.reactive.core.ReactivePulsarConsumerFactory<T>
• org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListenerMessageConsumerBuilderCustomizer<T>
• org.springframework.pulsar.reactive.listener.ReactivePulsarMessageHandler
  • org.springframework.pulsar.reactive.listener.ReactivePulsarOneByOneMessageHandler<T>
  • org.springframework.pulsar.reactive.listener.ReactivePulsarStreamingHandler<T>
• org.springframework.pulsar.reactive.core.ReactivePulsarOperations<T>
• org.springframework.pulsar.reactive.core.ReactivePulsarOperations.SendMessageBuilder<O,T>
  • org.springframework.pulsar.reactive.core.ReactivePulsarOperations.SendManyMessageBuilder<T>
  • org.springframework.pulsar.reactive.core.ReactivePulsarOperations.SendOneMessageBuilder<T>
• org.springframework.pulsar.reactive.core.ReactivePulsarReaderFactory<T>
• org.springframework.pulsar.reactive.core.ReactivePulsarSenderFactory<T>
• org.springframework.pulsar.core.ReaderBuilderCustomizer<T>
• org.springframework.pulsar.config.ReaderContainerFactory<C,E>
  • org.springframework.pulsar.config.PulsarReaderContainerFactory
• org.springframework.pulsar.core.SchemaResolver
• org.springframework.pulsar.core.SchemaResolver.SchemaResolverCustomizer<T>
• java.io.Serializable
  • org.apache.pulsar.client.api.MessageListener<T>
    • org.springframework.pulsar.listener.PulsarRecordMessageListener<T>
      • org.springframework.pulsar.listener.PulsarAcknowledgingMessageListener<T>
      • org.springframework.pulsar.listener.PulsarBatchMessageListener<T>
        • org.springframework.pulsar.listener.PulsarBatchAcknowledgingMessageListener<T>
• org.springframework.pulsar.core.TopicResolver
• org.springframework.transaction.TransactionManager
  • org.springframework.transaction.PlatformTransactionManager
    • org.springframework.pulsar.transaction.PulsarAwareTransactionManager
• org.springframework.pulsar.core.TypedMessageBuilderCustomizer<T>

Annotation Interface Hierarchy

• org.springframework.pulsar.annotation.EnablePulsar (implements java.lang.annotation.Annotation)
• org.springframework.pulsar.reactive.config.annotation.EnableReactivePulsar (implements java.lang.annotation.Annotation)
• org.springframework.pulsar.annotation.PulsarListener (implements java.lang.annotation.Annotation)
• org.springframework.pulsar.annotation.PulsarListeners (implements java.lang.annotation.Annotation)
• org.springframework.pulsar.annotation.PulsarMessage (implements java.lang.annotation.Annotation)
• org.springframework.pulsar.annotation.PulsarReader (implements java.lang.annotation.Annotation)
• org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListener (implements java.lang.annotation.Annotation)
• org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListeners (implements java.lang.annotation.Annotation)

Enum Class Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)
    • org.springframework.pulsar.listener.AckMode
    • org.springframework.pulsar.function.PulsarFunctionOperations.FunctionStopPolicy
    • org.springframework.pulsar.function.PulsarFunctionOperations.FunctionType
    • org.springframework.pulsar.observation.PulsarListenerObservation (implements io.micrometer.observation.docs.ObservationDocumentation)
    • org.springframework.pulsar.observation.PulsarListenerObservation.ListenerLowCardinalityTags (implements io.micrometer.common.docs.KeyName)
    • org.springframework.pulsar.observation.PulsarTemplateObservation (implements io.micrometer.observation.docs.ObservationDocumentation)
    • org.springframework.pulsar.observation.PulsarTemplateObservation.TemplateLowCardinalityTags (implements io.micrometer.common.docs.KeyName)