Hierarchy For All Packages

Package Hierarchies:

• org.apache.pulsar.spring,
• org.apache.pulsar.spring.annotation,
• org.apache.pulsar.spring.aot,
• org.apache.pulsar.spring.boot.autoconfigure,
• org.apache.pulsar.spring.cache.provider,
• org.apache.pulsar.spring.cache.provider.caffeine,
• org.apache.pulsar.spring.cloud.stream.binder,
• org.apache.pulsar.spring.cloud.stream.binder.config,
• org.apache.pulsar.spring.cloud.stream.binder.properties,
• org.apache.pulsar.spring.cloud.stream.binder.provisioning,
• org.apache.pulsar.spring.config,
• org.apache.pulsar.spring.core,
• org.apache.pulsar.spring.event,
• org.apache.pulsar.spring.function,
• org.apache.pulsar.spring.listener,
• org.apache.pulsar.spring.listener.adapter,
• org.apache.pulsar.spring.observation,
• org.apache.pulsar.spring.reader,
• org.apache.pulsar.spring.support,
• org.apache.pulsar.spring.support.converter,
• org.apache.pulsar.spring.support.header,
• org.apache.pulsar.spring.support.internal.logging,
• org.apache.pulsar.spring.transaction

Class Hierarchy

• java.lang.Object
  • org.springframework.cloud.stream.binder.AbstractBinder<T,C,P> (implements org.springframework.context.ApplicationContextAware, org.springframework.cloud.stream.binder.Binder<T,C,P>, org.springframework.beans.factory.InitializingBean)
    • org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<C,P,PP> (implements org.springframework.context.ApplicationEventPublisherAware, org.springframework.cloud.stream.binder.PollableConsumerBinder<H,C>)
      • org.apache.pulsar.spring.cloud.stream.binder.PulsarMessageChannelBinder (implements org.springframework.cloud.stream.binder.ExtendedPropertiesBinder<T,C,P>)
  • org.springframework.cloud.stream.binder.AbstractExtendedBindingProperties<C,P,T> (implements org.springframework.context.ApplicationContextAware, org.springframework.cloud.stream.binder.ExtendedBindingProperties<C,P>)
    • org.apache.pulsar.spring.cloud.stream.binder.properties.PulsarExtendedBindingProperties
  • org.springframework.transaction.support.AbstractPlatformTransactionManager (implements org.springframework.transaction.ConfigurableTransactionManager, org.springframework.transaction.PlatformTransactionManager, java.io.Serializable)
    • org.apache.pulsar.spring.transaction.PulsarTransactionManager (implements org.apache.pulsar.spring.transaction.PulsarAwareTransactionManager)
  • org.apache.pulsar.spring.annotation.AbstractPulsarAnnotationsBeanPostProcessor (implements org.springframework.context.ApplicationContextAware, org.springframework.beans.factory.config.BeanPostProcessor, org.springframework.beans.factory.InitializingBean, org.springframework.core.Ordered)
    • org.apache.pulsar.spring.annotation.PulsarListenerAnnotationBeanPostProcessor<V> (implements org.springframework.beans.factory.SmartInitializingSingleton)
    • org.apache.pulsar.spring.annotation.PulsarReaderAnnotationBeanPostProcessor<V> (implements org.springframework.beans.factory.SmartInitializingSingleton)
  • org.apache.pulsar.spring.annotation.AbstractPulsarAnnotationsBeanPostProcessor.ListenerScope (implements org.springframework.beans.factory.config.Scope)
  • org.apache.pulsar.spring.annotation.AbstractPulsarAnnotationsBeanPostProcessor.PulsarHandlerMethodFactoryAdapter (implements org.springframework.messaging.handler.annotation.support.MessageHandlerMethodFactory)
  • org.apache.pulsar.spring.support.header.AbstractPulsarHeaderMapper<ToPulsarHeadersContextType, ToSpringHeadersContextType> (implements org.apache.pulsar.spring.support.header.PulsarHeaderMapper)
    • org.apache.pulsar.spring.support.header.JsonPulsarHeaderMapper
    • org.apache.pulsar.spring.support.header.ToStringPulsarHeaderMapper
  • org.apache.pulsar.spring.config.AbstractPulsarListenerContainerFactory<C,T> (implements org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationEventPublisherAware, org.apache.pulsar.spring.config.PulsarListenerContainerFactory)
    • org.apache.pulsar.spring.config.ConcurrentPulsarListenerContainerFactory<T>
  • org.apache.pulsar.spring.config.AbstractPulsarListenerEndpoint<K> (implements org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, org.apache.pulsar.spring.config.PulsarListenerEndpoint)
    • org.apache.pulsar.spring.config.MethodPulsarListenerEndpoint<V>
  • org.apache.pulsar.spring.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.apache.pulsar.spring.listener.AbstractPulsarMessageListenerContainer<T> (implements org.apache.pulsar.spring.listener.PulsarMessageListenerContainer)
      • org.apache.pulsar.spring.listener.ConcurrentPulsarMessageListenerContainer<T>
      • org.apache.pulsar.spring.listener.DefaultPulsarMessageListenerContainer<T>
    • org.apache.pulsar.spring.reader.AbstractPulsarMessageReaderContainer<T> (implements org.apache.pulsar.spring.reader.PulsarMessageReaderContainer)
      • org.apache.pulsar.spring.reader.DefaultPulsarMessageReaderContainer<T>
  • org.apache.pulsar.spring.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter<V>
    • org.apache.pulsar.spring.listener.adapter.PulsarBatchMessagesToSpringMessageListenerAdapter<V> (implements org.apache.pulsar.spring.listener.PulsarBatchAcknowledgingMessageListener<T>)
    • org.apache.pulsar.spring.listener.adapter.PulsarRecordMessageToSpringMessageListenerAdapter<V> (implements org.apache.pulsar.spring.listener.PulsarAcknowledgingMessageListener<T>)
    • org.apache.pulsar.spring.listener.adapter.PulsarRecordMessageToSpringMessageReaderAdapter<V> (implements org.apache.pulsar.client.api.ReaderListener<T>)
  • org.apache.pulsar.spring.config.AbstractPulsarReaderContainerFactory<C,T> (implements org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationEventPublisherAware, org.apache.pulsar.spring.config.PulsarReaderContainerFactory)
    • org.apache.pulsar.spring.config.DefaultPulsarReaderContainerFactory<T>
  • org.apache.pulsar.spring.config.AbstractPulsarReaderEndpoint<K> (implements org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, org.apache.pulsar.spring.config.PulsarReaderEndpoint<C>)
    • org.apache.pulsar.spring.config.MethodPulsarReaderEndpoint<V>
  • org.apache.pulsar.spring.cache.provider.caffeine.CaffeineCacheProvider<K,V> (implements org.apache.pulsar.spring.cache.provider.CacheProvider<K,V>)
  • org.apache.pulsar.spring.cache.provider.caffeine.CaffeineCacheProviderFactory<K,V> (implements org.apache.pulsar.spring.cache.provider.CacheProviderFactory<K,V>)
  • org.apache.pulsar.spring.core.ConsumerBuilderConfigurationUtil
  • org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties.Acknowledgement
  • org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties.Chunking
  • org.apache.pulsar.spring.core.DefaultExpressionResolver (implements org.apache.pulsar.spring.core.ExpressionResolver)
  • org.apache.pulsar.spring.core.DefaultPulsarClientFactory (implements org.springframework.context.EnvironmentAware, org.apache.pulsar.spring.core.PulsarClientFactory)
  • org.apache.pulsar.spring.listener.DefaultPulsarConsumerErrorHandler<T> (implements org.apache.pulsar.spring.listener.PulsarConsumerErrorHandler<T>)
  • org.apache.pulsar.spring.core.DefaultPulsarConsumerFactory<T> (implements org.apache.pulsar.spring.core.PulsarConsumerFactory<T>)
  • org.apache.pulsar.spring.observation.DefaultPulsarListenerObservationConvention (implements org.apache.pulsar.spring.observation.PulsarListenerObservationConvention)
  • org.apache.pulsar.spring.core.DefaultPulsarProducerFactory<T> (implements org.apache.pulsar.spring.core.PulsarProducerFactory<T>)
    • org.apache.pulsar.spring.core.CachingPulsarProducerFactory<T>
  • org.apache.pulsar.spring.core.DefaultPulsarReaderFactory<T> (implements org.apache.pulsar.spring.core.PulsarReaderFactory<T>)
  • org.apache.pulsar.spring.observation.DefaultPulsarTemplateObservationConvention (implements org.apache.pulsar.spring.observation.PulsarTemplateObservationConvention)
  • org.apache.pulsar.spring.core.DefaultSchemaResolver (implements org.springframework.beans.factory.BeanClassLoaderAware, org.apache.pulsar.spring.core.SchemaResolver)
  • org.apache.pulsar.spring.core.DefaultTopicResolver (implements org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.BeanFactoryAware, org.apache.pulsar.spring.core.TopicResolver)
  • org.apache.pulsar.spring.listener.adapter.DelegatingInvocableHandler
  • java.util.EventObject (implements java.io.Serializable)
    • org.springframework.context.ApplicationEvent
      • org.apache.pulsar.spring.event.PulsarEvent
        • org.apache.pulsar.spring.event.ConsumerFailedToStartEvent
        • org.apache.pulsar.spring.event.ConsumerStartedEvent
        • org.apache.pulsar.spring.event.ConsumerStartingEvent
        • org.apache.pulsar.spring.event.ReaderFailedToStartEvent
        • org.apache.pulsar.spring.event.ReaderStartedEvent
        • org.apache.pulsar.spring.event.ReaderStartingEvent
  • org.apache.pulsar.spring.cloud.stream.binder.config.ExtendedBindingHandlerMappingsProviderConfiguration
  • org.apache.pulsar.spring.config.GenericListenerEndpointRegistry<C,E> (implements org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<E>, org.springframework.beans.factory.DisposableBean, org.apache.pulsar.spring.listener.PulsarListenerContainerRegistry, org.springframework.context.SmartLifecycle)
    • org.apache.pulsar.spring.config.PulsarListenerEndpointRegistry
  • org.apache.pulsar.spring.config.GenericReaderEndpointRegistry<C,E> (implements org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<E>, org.springframework.beans.factory.DisposableBean, org.apache.pulsar.spring.reader.PulsarReaderContainerRegistry, org.springframework.context.SmartLifecycle)
    • org.apache.pulsar.spring.config.PulsarReaderEndpointRegistry
  • org.apache.pulsar.spring.listener.adapter.HandlerAdapter
  • org.apache.pulsar.spring.listener.adapter.InvocationResult
  • org.apache.pulsar.spring.support.header.JacksonUtils
  • org.apache.pulsar.spring.support.JavaUtils
  • org.apache.pulsar.spring.support.header.JsonPulsarHeaderMapper.JsonPulsarHeaderMapperBuilder
  • org.apache.pulsar.spring.core.JSONSchemaUtil.CustomJacksonJsonReader<T> (implements org.apache.pulsar.client.api.schema.SchemaReader<T>)
  • org.apache.pulsar.spring.core.JSONSchemaUtil.CustomJacksonJsonWriter<T> (implements org.apache.pulsar.client.api.schema.SchemaWriter<T>)
  • org.apache.pulsar.spring.support.internal.logging.LambdaCustomizerWarnLogger
  • io.micrometer.observation.Observation.Context (implements io.micrometer.observation.Observation.ContextView)
    • io.micrometer.observation.transport.ReceiverContext<C>
      • org.apache.pulsar.spring.observation.PulsarMessageReceiverContext
    • io.micrometer.observation.transport.SenderContext<C>
      • org.apache.pulsar.spring.observation.PulsarMessageSenderContext
  • org.springframework.messaging.handler.annotation.support.PayloadMethodArgumentResolver (implements org.springframework.messaging.handler.invocation.HandlerMethodArgumentResolver)
    • org.apache.pulsar.spring.annotation.PulsarNullAwarePayloadArgumentResolver
  • org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties.Batching
  • org.apache.pulsar.spring.core.PulsarAdministration (implements org.springframework.context.ApplicationContextAware, org.apache.pulsar.spring.core.PulsarAdministrationOperations, org.springframework.beans.factory.SmartInitializingSingleton)
  • org.apache.pulsar.spring.annotation.PulsarAnnotationsConfigurationSelector (implements org.springframework.context.annotation.DeferredImportSelector)
  • org.apache.pulsar.spring.config.PulsarAnnotationSupportBeanNames
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarAutoConfiguration
  • org.apache.pulsar.spring.cloud.stream.binder.config.PulsarBinderConfiguration
  • org.apache.pulsar.spring.cloud.stream.binder.properties.PulsarBinderConfigurationProperties
  • org.apache.pulsar.spring.cloud.stream.binder.properties.PulsarBindingProperties (implements org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider)
  • org.apache.pulsar.spring.annotation.PulsarBootstrapConfiguration (implements org.springframework.context.annotation.ImportBeanDefinitionRegistrar)
  • org.apache.pulsar.spring.listener.PulsarContainerProperties
  • org.apache.pulsar.spring.listener.PulsarDeadLetterPublishingRecoverer<T> (implements org.apache.pulsar.spring.listener.PulsarMessageRecovererFactory<T>)
  • org.apache.pulsar.spring.function.PulsarFunctionAdministration (implements org.springframework.context.SmartLifecycle)
  • org.apache.pulsar.spring.support.header.PulsarHeaderMatcher.NeverMatch (implements org.apache.pulsar.spring.support.header.PulsarHeaderMatcher)
  • org.apache.pulsar.spring.support.header.PulsarHeaderMatcher.PatternMatch (implements org.apache.pulsar.spring.support.header.PulsarHeaderMatcher)
  • org.apache.pulsar.spring.annotation.PulsarHeaderObjectMapperUtils
  • org.apache.pulsar.spring.support.PulsarHeaders
  • org.apache.pulsar.spring.config.PulsarListenerEndpointRegistrar (implements org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean)
  • org.apache.pulsar.spring.observation.PulsarMessageSenderContext.MessageHolder
  • org.apache.pulsar.spring.support.PulsarNull
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Admin
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Authentication
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Client
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer
    • org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties
      • org.apache.pulsar.spring.cloud.stream.binder.properties.PulsarConsumerProperties
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer.DeadLetterPolicy
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer.Subscription
    • org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties.Subscription
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Defaults
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Defaults.Topic
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Failover
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Failover.BackupCluster
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Function
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Listener
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Producer
    • org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties
      • org.apache.pulsar.spring.cloud.stream.binder.properties.PulsarProducerProperties
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Producer.Cache
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Reader
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Template
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Threads
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Transaction
  • org.apache.pulsar.spring.reader.PulsarReaderContainerProperties
  • org.apache.pulsar.spring.config.PulsarReaderEndpointRegistrar (implements org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean)
  • org.apache.pulsar.spring.support.converter.PulsarRecordMessageConverter<V> (implements org.apache.pulsar.spring.support.converter.PulsarMessageConverter<T>)
  • org.apache.pulsar.spring.aot.PulsarRuntimeHints (implements org.springframework.aot.hint.RuntimeHintsRegistrar)
  • org.apache.pulsar.spring.core.PulsarTemplate<T> (implements org.springframework.context.ApplicationContextAware, org.springframework.beans.factory.BeanNameAware, org.apache.pulsar.spring.core.PulsarOperations<T>, org.springframework.beans.factory.SmartInitializingSingleton)
  • org.apache.pulsar.spring.core.PulsarTemplate.SendMessageBuilderImpl<T> (implements org.apache.pulsar.spring.core.PulsarOperations.SendMessageBuilder<T>)
  • org.apache.pulsar.spring.core.PulsarTopicBuilder
  • org.apache.pulsar.spring.cloud.stream.binder.provisioning.PulsarTopicProvisioner (implements org.springframework.cloud.stream.provisioning.ProvisioningProvider<C,P>)
  • org.apache.pulsar.spring.transaction.PulsarTransactionUtils
  • org.apache.pulsar.spring.core.Resolved<T>
  • org.springframework.transaction.support.ResourceHolderSupport (implements org.springframework.transaction.support.ResourceHolder)
    • org.apache.pulsar.spring.transaction.PulsarResourceHolder
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • org.springframework.core.NestedRuntimeException
          • org.apache.pulsar.spring.PulsarException
            • org.apache.pulsar.spring.listener.PulsarBatchListenerFailedException
            • org.apache.pulsar.spring.function.PulsarFunctionAdministration.PulsarFunctionException
  • org.apache.pulsar.spring.core.TransactionProperties
    • org.apache.pulsar.spring.listener.PulsarContainerProperties.TransactionSettings

Interface Hierarchy

• org.apache.pulsar.spring.listener.Acknowledgement
• org.apache.pulsar.spring.cache.provider.CacheProvider<K,V>
• org.apache.pulsar.spring.cache.provider.CacheProviderFactory<K,V>
• org.apache.pulsar.spring.cache.provider.CacheProviderFactory.EvictionListener<K,V>
• org.springframework.boot.autoconfigure.service.connection.ConnectionDetails
  • org.apache.pulsar.spring.boot.autoconfigure.PulsarConnectionDetails
• org.apache.pulsar.spring.core.ConsumerBuilderCustomizer<T>
• org.springframework.beans.factory.DisposableBean
  • org.apache.pulsar.spring.listener.MessageListenerContainer (also extends org.springframework.context.SmartLifecycle)
    • org.apache.pulsar.spring.listener.PulsarMessageListenerContainer
  • org.apache.pulsar.spring.reader.PulsarMessageReaderContainer (also extends org.springframework.context.SmartLifecycle)
• org.apache.pulsar.spring.core.ExpressionResolver
• org.apache.pulsar.spring.core.JSONSchemaUtil
• io.micrometer.observation.KeyValuesConvention
  • io.micrometer.observation.ObservationConvention<T>
    • org.apache.pulsar.spring.observation.PulsarListenerObservationConvention
    • org.apache.pulsar.spring.observation.PulsarTemplateObservationConvention
• org.springframework.context.Lifecycle
  • org.springframework.context.SmartLifecycle (also extends org.springframework.context.Phased)
    • org.apache.pulsar.spring.listener.MessageListenerContainer (also extends org.springframework.beans.factory.DisposableBean)
      • org.apache.pulsar.spring.listener.PulsarMessageListenerContainer
    • org.apache.pulsar.spring.reader.PulsarMessageReaderContainer (also extends org.springframework.beans.factory.DisposableBean)
• org.apache.pulsar.spring.config.ListenerEndpoint<C>
  • org.apache.pulsar.spring.config.PulsarListenerEndpoint
• org.apache.pulsar.spring.support.MessageConverter
  • org.apache.pulsar.spring.support.converter.PulsarMessageConverter<T>
• org.springframework.context.Phased
  • org.springframework.context.SmartLifecycle (also extends org.springframework.context.Lifecycle)
    • org.apache.pulsar.spring.listener.MessageListenerContainer (also extends org.springframework.beans.factory.DisposableBean)
      • org.apache.pulsar.spring.listener.PulsarMessageListenerContainer
    • org.apache.pulsar.spring.reader.PulsarMessageReaderContainer (also extends org.springframework.beans.factory.DisposableBean)
• org.apache.pulsar.spring.core.ProducerBuilderCustomizer<T>
• org.apache.pulsar.spring.core.PulsarAdminBuilderCustomizer
• org.apache.pulsar.spring.core.PulsarAdministrationOperations
• org.apache.pulsar.spring.core.PulsarClientBuilderCustomizer
• org.apache.pulsar.spring.core.PulsarClientFactory
• org.apache.pulsar.spring.listener.PulsarConsumerErrorHandler<T>
• org.apache.pulsar.spring.core.PulsarConsumerFactory<T>
• org.apache.pulsar.spring.config.PulsarContainerFactory<C,E>
  • org.apache.pulsar.spring.config.ListenerContainerFactory<C,E>
    • org.apache.pulsar.spring.config.PulsarListenerContainerFactory
  • org.apache.pulsar.spring.config.ReaderContainerFactory<C,E>
    • org.apache.pulsar.spring.config.PulsarReaderContainerFactory
• org.apache.pulsar.spring.boot.autoconfigure.PulsarContainerFactoryCustomizer<T>
• org.apache.pulsar.spring.function.PulsarFunctionOperations<T>
• org.apache.pulsar.spring.support.header.PulsarHeaderMapper
• org.apache.pulsar.spring.support.header.PulsarHeaderMatcher
• org.apache.pulsar.spring.annotation.PulsarListenerConfigurer
• org.apache.pulsar.spring.annotation.PulsarListenerConsumerBuilderCustomizer<T>
• org.apache.pulsar.spring.listener.PulsarListenerContainerRegistry
• org.apache.pulsar.spring.listener.PulsarMessageRecoverer<T>
• org.apache.pulsar.spring.listener.PulsarMessageRecovererFactory<T>
• org.apache.pulsar.spring.core.PulsarOperations<T>
• org.apache.pulsar.spring.core.PulsarOperations.SendMessageBuilder<T>
• org.apache.pulsar.spring.core.PulsarProducerFactory<T>
• org.apache.pulsar.spring.annotation.PulsarReaderConfigurer
• org.apache.pulsar.spring.reader.PulsarReaderContainerRegistry
• org.apache.pulsar.spring.config.PulsarReaderEndpoint<C>
• org.apache.pulsar.spring.core.PulsarReaderFactory<T>
• org.apache.pulsar.spring.annotation.PulsarReaderReaderBuilderCustomizer<T>
• org.apache.pulsar.spring.core.PulsarTemplate.TemplateCallback<T,R>
• org.apache.pulsar.spring.core.PulsarTemplateCustomizer<T>
• org.apache.pulsar.spring.core.ReaderBuilderCustomizer<T>
• org.apache.pulsar.spring.core.SchemaResolver
• org.apache.pulsar.spring.core.SchemaResolver.SchemaResolverCustomizer<T>
• java.io.Serializable
  • org.apache.pulsar.client.api.MessageListener<T>
    • org.apache.pulsar.spring.listener.PulsarRecordMessageListener<T>
      • org.apache.pulsar.spring.listener.PulsarAcknowledgingMessageListener<T>
      • org.apache.pulsar.spring.listener.PulsarBatchMessageListener<T>
        • org.apache.pulsar.spring.listener.PulsarBatchAcknowledgingMessageListener<T>
• org.apache.pulsar.spring.core.TopicResolver
• org.springframework.transaction.TransactionManager
  • org.springframework.transaction.PlatformTransactionManager
    • org.apache.pulsar.spring.transaction.PulsarAwareTransactionManager
• org.apache.pulsar.spring.core.TypedMessageBuilderCustomizer<T>

Annotation Interface Hierarchy

• org.apache.pulsar.spring.annotation.EnablePulsar (implements java.lang.annotation.Annotation)
• org.apache.pulsar.spring.annotation.PulsarListener (implements java.lang.annotation.Annotation)
• org.apache.pulsar.spring.annotation.PulsarListeners (implements java.lang.annotation.Annotation)
• org.apache.pulsar.spring.annotation.PulsarMessage (implements java.lang.annotation.Annotation)
• org.apache.pulsar.spring.annotation.PulsarReader (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.apache.pulsar.spring.listener.AckMode
    • org.apache.pulsar.spring.function.PulsarFunctionOperations.FunctionStopPolicy
    • org.apache.pulsar.spring.function.PulsarFunctionOperations.FunctionType
    • org.apache.pulsar.spring.observation.PulsarListenerObservation (implements io.micrometer.observation.docs.ObservationDocumentation)
    • org.apache.pulsar.spring.observation.PulsarListenerObservation.ListenerLowCardinalityTags (implements io.micrometer.common.docs.KeyName)
    • org.apache.pulsar.spring.observation.PulsarTemplateObservation (implements io.micrometer.observation.docs.ObservationDocumentation)
    • org.apache.pulsar.spring.observation.PulsarTemplateObservation.TemplateLowCardinalityTags (implements io.micrometer.common.docs.KeyName)
    • org.apache.pulsar.spring.config.StartupFailurePolicy

Record Class Hierarchy

• java.lang.Object
  • java.lang.Record
    • org.apache.pulsar.spring.support.header.JsonPulsarHeaderMapper.NonTrustedHeaderType
    • org.apache.pulsar.spring.support.header.JsonPulsarHeaderMapper.ToPulsarHeadersContext
    • org.apache.pulsar.spring.support.header.JsonPulsarHeaderMapper.ToSpringHeadersContext
    • org.apache.pulsar.spring.function.PulsarFunction (implements org.apache.pulsar.spring.function.PulsarFunctionOperations<T>)
    • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Defaults.SchemaInfo
    • org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Defaults.TypeMapping
    • org.apache.pulsar.spring.function.PulsarSink (implements org.apache.pulsar.spring.function.PulsarFunctionOperations<T>)
    • org.apache.pulsar.spring.function.PulsarSource (implements org.apache.pulsar.spring.function.PulsarFunctionOperations<T>)
    • org.apache.pulsar.spring.core.PulsarTopic