All Classes and Interfaces

Class	Description
AbstractPulsarConfiguration<K,V>	Base template class for configuring pulsar.
AvroSchemaResolver	AVRO schema resolver.
ConsumerSubscribedEvent	Produced when Pulsar consumer connects to a broker and starts listening to specified topics.
ConsumerSubscriptionFailedEvent	Raise error event on failed subscription.
DefaultListener	Default listener for incoming Pulsar messages.
DefaultPulsarClientConfiguration	Default properties holder for Pulsar client configuration.
DefaultSchemaHandler	Message type resolver for Pulsar schema.
JsonReader<T>	JSON Schema Reader to allow using JsonMapper from Micronaut instead of shaded one in Pulsar library.
JsonSchema<T>	JSON Schema to allow using JsonMapper from Micronaut instead of shaded one in Pulsar library.
JsonSchemaResolver	JSON schema resolver.
JsonWriter<T>	JSON Schema Writer to allow using JsonMapper from Micronaut instead of shaded one in Pulsar library.
ListenerKotlinHelper	Kotlin helper class that bridges Java calls from Pulsar Java library into suspend calls to Kotlin.
MessageKey	Parameter level annotation to indicate which parameter is bound to the Pulsar message key.
MessageListenerResolver	Provides flexibility to implement MessageListener as beans while still being able to override default listener resolver for Pulsar Consumers.
MessageProperties	Parameter level annotation to indicate which parameter is bound to the message properties map.
MessageSchema	Supported schema types.
ProducerSubscriptionFailedEvent	Raise error event on failed producer subscription.
ProtobufReader<T>	Protobuf Schema Reader to allow using ProtobufferCodec from Micronaut.
ProtobufSchema<T>	JSON Schema to allow using ProtobufferCodec from Micronaut.
ProtobufSchemaResolver	Protobuf schema resolver.
ProtobufWriter<T>	Protobuf Schema Writer to allow using ProtobufferCodec from Micronaut.
PulsarArgumentHandler	Helper processor class for arguments and headers on Pulsar consumers / processors.
PulsarClientConfiguration	Basic requirements for custom and default configuration to create Pulsar client.
PulsarClientFactory	Create bean of PulsarClient type which is required by consumers and producers.
PulsarConsumer	Marks a method as a Pulsar Consumer.
PulsarConsumerProcessor	Processes beans containing methods annotated with @PulsarConsumer.
PulsarConsumerRegistry	A registry for created Pulsar consumers.
PulsarFailureEvent	Event raised on failure made by Pulsar client connection or reader, consumer, or producer errors.
PulsarMultitenantProducerAdvice	Intercepting pulsar Producer methods.
PulsarProducer	Marks a method that should produce values to Pulsar topics on call.
PulsarProducerAdvice	Intercepting pulsar Producer methods.
PulsarProducerClient	Marks a type as a bean containing producer methods.
PulsarProducerFactory	Pulsar Producer factory.
PulsarProducerRegistry	A registry of managed Producer instances key by id and type.
PulsarReader	Create and inject Pulsar reader into field.
PulsarReaderAdvice	Interceptor for abstract methods annotated with the PulsarReader.
PulsarReaderClient	Marks a type as a bean containing reader methods.
PulsarReaderFactory	Create pulsar reader beans for fields annotated with PulsarReader.
PulsarReaderRegistry	Keeps track of all created Pulsar readers.
PulsarServiceUrlProvider	Marks a class that contains a method to resolve the Pulsar service url.
PulsarSubscription	Mark a class that contains Pulsar consumers.
PulsarTenantDiscoveredEvent	Simple event to publish on new tenant discovery.
SchemaResolver	SchemaResolver represents basic bean that will handle serde operations for a given type.
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.