Package io.micronaut.pulsar.processor

package io.micronaut.pulsar.processor
Pulsar annotations processors for multitenancy.
Since:
1.2.0.
Author:
Haris Secic
  • Class
    Description
    DefaultListener
    Default listener for incoming Pulsar messages.
    DefaultSchemaHandler
    Message type resolver for Pulsar schema.
    ListenerKotlinHelper
    Kotlin helper class that bridges Java calls from Pulsar Java library into suspend calls to Kotlin.
    MessageListenerResolver
    Provides flexibility to implement MessageListener as beans while still being able to override default listener resolver for Pulsar Consumers.
    PulsarArgumentHandler
    Helper processor class for arguments and headers on Pulsar consumers / processors.
    PulsarConsumerProcessor
    Processes beans containing methods annotated with @PulsarConsumer.
    TenantNameResolver
    Resolve tenant ID class representation to Apache Pulsar tenant name (as String).
    TopicResolver
    Process input string to determine real topic name for Apache Pulsar.
    TopicResolver.TopicResolved
    Simple container class for describing resolved topics.