Package io.micronaut.pulsar.processor

package io.micronaut.pulsar.processor

Pulsar annotations processors for multitenancy.

Since:

1.2.0.

Author:

Haris Secic

Related Packages

Package	Description
io.micronaut.pulsar	Entry point for Micronaut Pulsar integration.
io.micronaut.pulsar.annotation	Annotations for Pulsar consumers, producers, and readers.
io.micronaut.pulsar.config	Pulsar client configurations.
io.micronaut.pulsar.events	Custom Events for multitenant Pulsar consumers, readers, and producers.
io.micronaut.pulsar.intercept	Interceptors for multitenant methods annotated with Pulsar annotations.
io.micronaut.pulsar.schemas	Schema processors for data types by Pulsar consumers, producers, and readers.

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.