Hierarchy For All Packages

Package Hierarchies:

• io.micronaut.pulsar,
• io.micronaut.pulsar.annotation,
• io.micronaut.pulsar.config,
• io.micronaut.pulsar.events,
• io.micronaut.pulsar.intercept,
• io.micronaut.pulsar.processor,
• io.micronaut.pulsar.schemas,
• io.micronaut.pulsar.schemas.avro,
• io.micronaut.pulsar.schemas.json,
• io.micronaut.pulsar.schemas.protobuf

Class Hierarchy

• java.lang.Object
  • io.micronaut.pulsar.config.AbstractPulsarConfiguration<K,V>
    • io.micronaut.pulsar.config.DefaultPulsarClientConfiguration (implements io.micronaut.pulsar.config.PulsarClientConfiguration)
  • org.apache.pulsar.client.impl.schema.AbstractSchema<T> (implements org.apache.pulsar.client.api.Schema<T>)
    • org.apache.pulsar.client.impl.schema.AbstractStructSchema<T>
      • org.apache.pulsar.client.impl.schema.AvroBaseStructSchema<T>
        • io.micronaut.pulsar.schemas.json.JsonSchema<T>
      • io.micronaut.pulsar.schemas.protobuf.ProtobufSchema<T>
  • io.micronaut.pulsar.schemas.avro.AvroSchemaResolver (implements io.micronaut.pulsar.schemas.SchemaResolver)
  • io.micronaut.pulsar.events.ConsumerSubscribedEvent
  • io.micronaut.pulsar.events.ConsumerSubscriptionFailedEvent (implements io.micronaut.pulsar.events.PulsarFailureEvent)
  • io.micronaut.pulsar.processor.DefaultListener (implements io.micronaut.pulsar.processor.MessageListenerResolver)
  • io.micronaut.pulsar.processor.DefaultSchemaHandler
  • io.micronaut.pulsar.schemas.json.JsonReader<T> (implements org.apache.pulsar.client.api.schema.SchemaReader<T>)
  • io.micronaut.pulsar.schemas.json.JsonSchemaResolver (implements io.micronaut.pulsar.schemas.SchemaResolver)
  • io.micronaut.pulsar.schemas.json.JsonWriter<T> (implements org.apache.pulsar.client.api.schema.SchemaWriter<T>)
  • io.micronaut.pulsar.processor.ListenerKotlinHelper
  • io.micronaut.pulsar.events.ProducerSubscriptionFailedEvent (implements io.micronaut.pulsar.events.PulsarFailureEvent)
  • io.micronaut.pulsar.schemas.protobuf.ProtobufReader<T> (implements org.apache.pulsar.client.api.schema.SchemaReader<T>)
  • io.micronaut.pulsar.schemas.protobuf.ProtobufSchemaResolver (implements io.micronaut.pulsar.schemas.SchemaResolver)
  • io.micronaut.pulsar.schemas.protobuf.ProtobufWriter<T> (implements org.apache.pulsar.client.api.schema.SchemaWriter<T>)
  • io.micronaut.pulsar.processor.PulsarArgumentHandler
  • io.micronaut.pulsar.PulsarClientFactory
  • io.micronaut.pulsar.processor.PulsarConsumerProcessor (implements java.lang.AutoCloseable, io.micronaut.context.processor.ExecutableMethodProcessor<A>, io.micronaut.pulsar.PulsarConsumerRegistry)
  • io.micronaut.pulsar.intercept.PulsarProducerAdvice (implements java.lang.AutoCloseable, io.micronaut.aop.MethodInterceptor<T,R>, io.micronaut.pulsar.PulsarProducerRegistry)
    • io.micronaut.pulsar.intercept.PulsarMultitenantProducerAdvice (implements java.lang.AutoCloseable, io.micronaut.aop.MethodInterceptor<T,R>)
  • io.micronaut.pulsar.PulsarProducerFactory
  • io.micronaut.pulsar.intercept.PulsarReaderAdvice (implements io.micronaut.aop.MethodInterceptor<T,R>)
  • io.micronaut.pulsar.PulsarReaderFactory (implements java.lang.AutoCloseable, io.micronaut.pulsar.PulsarReaderRegistry)
  • io.micronaut.pulsar.events.PulsarTenantDiscoveredEvent
  • io.micronaut.pulsar.processor.TopicResolver.TopicResolved

Interface Hierarchy

• io.micronaut.pulsar.config.PulsarClientConfiguration
• io.micronaut.pulsar.PulsarConsumerRegistry
• io.micronaut.pulsar.events.PulsarFailureEvent
• io.micronaut.pulsar.PulsarProducerRegistry
• io.micronaut.pulsar.PulsarReaderRegistry
• io.micronaut.pulsar.schemas.SchemaResolver
• java.io.Serializable
  • org.apache.pulsar.client.api.MessageListener<T>
    • io.micronaut.pulsar.processor.MessageListenerResolver
• io.micronaut.pulsar.processor.TenantNameResolver
• io.micronaut.pulsar.processor.TopicResolver

Annotation Interface Hierarchy

• io.micronaut.pulsar.annotation.MessageKey (implements java.lang.annotation.Annotation)
• io.micronaut.pulsar.annotation.MessageProperties (implements java.lang.annotation.Annotation)
• io.micronaut.pulsar.annotation.PulsarConsumer (implements java.lang.annotation.Annotation)
• io.micronaut.pulsar.annotation.PulsarProducer (implements java.lang.annotation.Annotation)
• io.micronaut.pulsar.annotation.PulsarProducerClient (implements java.lang.annotation.Annotation)
• io.micronaut.pulsar.annotation.PulsarReader (implements java.lang.annotation.Annotation)
• io.micronaut.pulsar.annotation.PulsarReaderClient (implements java.lang.annotation.Annotation)
• io.micronaut.pulsar.annotation.PulsarServiceUrlProvider (implements java.lang.annotation.Annotation)
• io.micronaut.pulsar.annotation.PulsarSubscription (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)
    • io.micronaut.pulsar.MessageSchema