A B C D E F G H I J L M O P R S T V W

A

AbstractPulsarConfiguration<K,V> - Class in io.micronaut.pulsar.config

Base template class for configuring pulsar.

AbstractPulsarConfiguration(Properties) - Constructor for class io.micronaut.pulsar.config.AbstractPulsarConfiguration

applicationEventPublisher - Variable in class io.micronaut.pulsar.intercept.PulsarProducerAdvice

argumentOrder() - Method in class io.micronaut.pulsar.processor.PulsarArgumentHandler

B

beanContext - Variable in class io.micronaut.pulsar.intercept.PulsarProducerAdvice

beanContext - Variable in class io.micronaut.pulsar.intercept.PulsarReaderAdvice

bodyType(Argument<?>) - Static method in class io.micronaut.pulsar.processor.DefaultSchemaHandler

C

clearTenantName() - Method in interface io.micronaut.pulsar.processor.TenantNameResolver

Clear out enforced tenant name set through TenantNameResolver.overrideTenantName(String).

close() - Method in class io.micronaut.pulsar.intercept.PulsarMultitenantProducerAdvice

close() - Method in class io.micronaut.pulsar.intercept.PulsarProducerAdvice

close() - Method in class io.micronaut.pulsar.processor.PulsarConsumerProcessor

close() - Method in class io.micronaut.pulsar.PulsarReaderFactory

consumerExists(String) - Method in class io.micronaut.pulsar.processor.PulsarConsumerProcessor

consumerExists(String) - Method in interface io.micronaut.pulsar.PulsarConsumerRegistry

ConsumerSubscribedEvent - Class in io.micronaut.pulsar.events

Produced when Pulsar consumer connects to a broker and starts listening to specified topics.

ConsumerSubscribedEvent(Consumer<?>) - Constructor for class io.micronaut.pulsar.events.ConsumerSubscribedEvent

ConsumerSubscriptionFailedEvent - Class in io.micronaut.pulsar.events

Raise error event on failed subscription.

ConsumerSubscriptionFailedEvent(Throwable, String) - Constructor for class io.micronaut.pulsar.events.ConsumerSubscriptionFailedEvent

createProducer(PulsarClient, AnnotationValue<PulsarProducer>, Argument<?>[], DefaultSchemaHandler, String) - Method in class io.micronaut.pulsar.PulsarProducerFactory

Simple factory method for producing Pulsar Producer beans.

D

decideSchema(Argument<?>, Argument<?>, AnnotationValue<?>, String) - Method in class io.micronaut.pulsar.processor.DefaultSchemaHandler

Resolve which schema to use for ser/der.

DEFAULT_BOOTSTRAP_SERVER - Static variable in class io.micronaut.pulsar.config.AbstractPulsarConfiguration

The default bootstrap server address for messaging.

DEFAULT_PULSAR_AUTHENTICATION - Static variable in class io.micronaut.pulsar.config.AbstractPulsarConfiguration

By default Pulsar doesn't have any authentication.

DEFAULT_PULSAR_MESSAGING_PORT - Static variable in class io.micronaut.pulsar.config.AbstractPulsarConfiguration

The default Apache Pulsar messaging port.

DEFAULT_SERVER_HOST_ADDRESS - Static variable in class io.micronaut.pulsar.config.AbstractPulsarConfiguration

The default server hostname or IP address.

DefaultListener - Class in io.micronaut.pulsar.processor

Default listener for incoming Pulsar messages.

DefaultListener(ExecutableMethod, boolean, Object, PulsarArgumentHandler) - Constructor for class io.micronaut.pulsar.processor.DefaultListener

DefaultPulsarClientConfiguration - Class in io.micronaut.pulsar.config

Default properties holder for Pulsar client configuration.

DefaultPulsarClientConfiguration(Environment, Optional<ServiceUrlProvider>) - Constructor for class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

Constructs the default Pulsar Client configuration.

DefaultSchemaHandler - Class in io.micronaut.pulsar.processor

Message type resolver for Pulsar schema.

DefaultSchemaHandler(BeanContext) - Constructor for class io.micronaut.pulsar.processor.DefaultSchemaHandler

E

extractTopic(AnnotationValue<?>) - Static method in interface io.micronaut.pulsar.processor.TopicResolver

F

forArgument(Class<?>) - Method in class io.micronaut.pulsar.schemas.json.JsonSchemaResolver

forArgument(Class<?>) - Method in class io.micronaut.pulsar.schemas.protobuf.ProtobufSchemaResolver

forArgument(Class<?>) - Method in interface io.micronaut.pulsar.schemas.SchemaResolver

G

generateIdFromMessagingClientName(String, TopicResolver.TopicResolved) - Method in interface io.micronaut.pulsar.processor.TopicResolver

getAuthentication() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

getAuthentication() - Method in interface io.micronaut.pulsar.config.PulsarClientConfiguration

getBodyArgument() - Method in class io.micronaut.pulsar.processor.PulsarArgumentHandler

getConfig() - Method in class io.micronaut.pulsar.config.AbstractPulsarConfiguration

getConsumer() - Method in class io.micronaut.pulsar.events.ConsumerSubscribedEvent

getConsumer(String) - Method in class io.micronaut.pulsar.processor.PulsarConsumerProcessor

getConsumer(String) - Method in interface io.micronaut.pulsar.PulsarConsumerRegistry

getConsumerIds() - Method in class io.micronaut.pulsar.processor.PulsarConsumerProcessor

getConsumerIds() - Method in interface io.micronaut.pulsar.PulsarConsumerRegistry

getConsumerName() - Method in class io.micronaut.pulsar.events.ConsumerSubscriptionFailedEvent

getConsumerName(AnnotationValue<PulsarConsumer>) - Method in class io.micronaut.pulsar.processor.PulsarConsumerProcessor

Resolve topic name from the PulsarConsumer annotation.

getConsumers() - Method in class io.micronaut.pulsar.processor.PulsarConsumerProcessor

getConsumers() - Method in interface io.micronaut.pulsar.PulsarConsumerRegistry

getCurrentTenantName() - Method in interface io.micronaut.pulsar.processor.TenantNameResolver

Resolve current tenant name from tenant ID or overridden value set through TenantNameResolver.overrideTenantName(String).

getDefaultMaxRetryDlq() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

getDefaultTenant() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

getDefaultTenant() - Method in interface io.micronaut.pulsar.config.PulsarClientConfiguration

getIoThreads() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

getIoThreads() - Method in interface io.micronaut.pulsar.config.PulsarClientConfiguration

getKeyArgument() - Method in class io.micronaut.pulsar.processor.PulsarArgumentHandler

getListenerThreads() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

getListenerThreads() - Method in interface io.micronaut.pulsar.config.PulsarClientConfiguration

getOauthAudience() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

Must be set for usage with the OAuth2 authentication.

getOauthCredentialsUrl() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

getOauthIssuerUrl() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

getOrCreateProducer(ExecutableMethod<?, ?>, AnnotationValue<PulsarProducer>) - Method in class io.micronaut.pulsar.intercept.PulsarMultitenantProducerAdvice

getOrCreateProducer(ExecutableMethod<?, ?>, AnnotationValue<PulsarProducer>) - Method in class io.micronaut.pulsar.intercept.PulsarProducerAdvice

Fetch existing producer or generate a new one via factory if missing.

getProducer(String) - Method in class io.micronaut.pulsar.intercept.PulsarMultitenantProducerAdvice

getProducer(String) - Method in class io.micronaut.pulsar.intercept.PulsarProducerAdvice

getProducer(String) - Method in interface io.micronaut.pulsar.PulsarProducerRegistry

Get single managed producer by its name.

getProducerIds() - Method in class io.micronaut.pulsar.intercept.PulsarMultitenantProducerAdvice

getProducerIds() - Method in class io.micronaut.pulsar.intercept.PulsarProducerAdvice

getProducerIds() - Method in interface io.micronaut.pulsar.PulsarProducerRegistry

Get all managed producer identifiers.

getProducerName() - Method in class io.micronaut.pulsar.events.ProducerSubscriptionFailedEvent

getProducers() - Method in class io.micronaut.pulsar.intercept.PulsarMultitenantProducerAdvice

getProducers() - Method in class io.micronaut.pulsar.intercept.PulsarProducerAdvice

getProducers() - Method in interface io.micronaut.pulsar.PulsarProducerRegistry

Get all managed producers.

getReader(String) - Method in class io.micronaut.pulsar.PulsarReaderFactory

getReader(String) - Method in interface io.micronaut.pulsar.PulsarReaderRegistry

If not specified explicitly, reader name will default to property/field name.

getReaderByInjectionPoint(BeanResolutionContext, AnnotationValue<PulsarReader>, Argument<?>, MethodInvocationContext<?, ?>) - Method in class io.micronaut.pulsar.PulsarReaderFactory

Create Pulsar Reader for given injection point if missing.

getReaders() - Method in class io.micronaut.pulsar.PulsarReaderFactory

getReaders() - Method in interface io.micronaut.pulsar.PulsarReaderRegistry

getReason() - Method in class io.micronaut.pulsar.events.ConsumerSubscriptionFailedEvent

getReason() - Method in class io.micronaut.pulsar.events.ProducerSubscriptionFailedEvent

getReason() - Method in interface io.micronaut.pulsar.events.PulsarFailureEvent

getSchemaResolverName() - Method in enum io.micronaut.pulsar.MessageSchema

getServiceUrl() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

getServiceUrl() - Method in interface io.micronaut.pulsar.config.PulsarClientConfiguration

getServiceUrlProvider() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

getServiceUrlProvider() - Method in interface io.micronaut.pulsar.config.PulsarClientConfiguration

getShutdownOnSubscriberError() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

getShutdownOnSubscriberError() - Method in interface io.micronaut.pulsar.config.PulsarClientConfiguration

getSourceError() - Method in class io.micronaut.pulsar.events.ConsumerSubscriptionFailedEvent

getSourceError() - Method in class io.micronaut.pulsar.events.ProducerSubscriptionFailedEvent

getSslProvider() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

getSslProvider() - Method in interface io.micronaut.pulsar.config.PulsarClientConfiguration

getTenant() - Method in class io.micronaut.pulsar.events.PulsarTenantDiscoveredEvent

getTlsAllowInsecureConnection() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

getTlsAllowInsecureConnection() - Method in interface io.micronaut.pulsar.config.PulsarClientConfiguration

getTlsCertFilePath() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

getTlsCertFilePath() - Method in interface io.micronaut.pulsar.config.PulsarClientConfiguration

getTlsCiphers() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

getTlsCiphers() - Method in interface io.micronaut.pulsar.config.PulsarClientConfiguration

getTlsProtocols() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

getTlsProtocols() - Method in interface io.micronaut.pulsar.config.PulsarClientConfiguration

getTlsTrustStorePath() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

getTlsTrustStorePath() - Method in interface io.micronaut.pulsar.config.PulsarClientConfiguration

getTlsVerifyHostname() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

getTlsVerifyHostname() - Method in interface io.micronaut.pulsar.config.PulsarClientConfiguration

getTopic() - Method in class io.micronaut.pulsar.processor.TopicResolver.TopicResolved

getTopics() - Method in class io.micronaut.pulsar.processor.TopicResolver.TopicResolved

getUseDeadLetterQueue() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

H

hasHeaderList() - Method in class io.micronaut.pulsar.processor.PulsarArgumentHandler

hasHeadersMap() - Method in class io.micronaut.pulsar.processor.PulsarArgumentHandler

hasTenantName() - Method in interface io.micronaut.pulsar.processor.TenantNameResolver

Check whether tenant name exists in the current request context or is enforced.

headersOrder() - Method in class io.micronaut.pulsar.processor.PulsarArgumentHandler

I

intercept(MethodInvocationContext<Object, Object>) - Method in class io.micronaut.pulsar.intercept.PulsarProducerAdvice

intercept(MethodInvocationContext<Object, Object>) - Method in class io.micronaut.pulsar.intercept.PulsarReaderAdvice

io.micronaut.pulsar - package io.micronaut.pulsar

Entry point for Micronaut Pulsar integration.

io.micronaut.pulsar.annotation - package io.micronaut.pulsar.annotation

Annotations for Pulsar consumers, producers, and readers.

io.micronaut.pulsar.config - package io.micronaut.pulsar.config

Pulsar client configurations.

io.micronaut.pulsar.events - package io.micronaut.pulsar.events

Custom Events for multitenant Pulsar consumers, readers, and producers.

io.micronaut.pulsar.intercept - package io.micronaut.pulsar.intercept

Interceptors for multitenant methods annotated with Pulsar annotations.

io.micronaut.pulsar.processor - package io.micronaut.pulsar.processor

Pulsar annotations processors for multitenancy.

io.micronaut.pulsar.schemas - package io.micronaut.pulsar.schemas

Schema processors for data types by Pulsar consumers, producers, and readers.

io.micronaut.pulsar.schemas.json - package io.micronaut.pulsar.schemas.json

JSON data type processor for Pulsar.

io.micronaut.pulsar.schemas.protobuf - package io.micronaut.pulsar.schemas.protobuf

isArray() - Method in class io.micronaut.pulsar.processor.TopicResolver.TopicResolved

isDynamicTenant() - Method in class io.micronaut.pulsar.processor.TopicResolver.TopicResolved

isDynamicTenantInTopic(String) - Static method in interface io.micronaut.pulsar.processor.TopicResolver

isMessageWrapper() - Method in class io.micronaut.pulsar.processor.PulsarArgumentHandler

isPattern() - Method in class io.micronaut.pulsar.processor.TopicResolver.TopicResolved

isPaused(String) - Method in class io.micronaut.pulsar.processor.PulsarConsumerProcessor

isPaused(String) - Method in interface io.micronaut.pulsar.PulsarConsumerRegistry

isStaticTenantResolver() - Method in interface io.micronaut.pulsar.processor.TenantNameResolver

isValidTenantName(String) - Static method in interface io.micronaut.pulsar.processor.TenantNameResolver

J

JacksonJsonReader<T> - Class in io.micronaut.pulsar.schemas.json

JSON Schema Reader to allow using ObjectMapper from Micronaut instead of shaded one in Pulsar library.

JacksonJsonReader(ObjectMapper, Class<T>) - Constructor for class io.micronaut.pulsar.schemas.json.JacksonJsonReader

Deprecated.

Use JacksonJsonReader(JsonMapper, Class) instead

JacksonJsonReader(JsonMapper, Class<T>) - Constructor for class io.micronaut.pulsar.schemas.json.JacksonJsonReader

JacksonJsonWriter<T> - Class in io.micronaut.pulsar.schemas.json

JSON Schema Writer to allow using ObjectMapper from Micronaut instead of shaded one in Pulsar library.

JacksonJsonWriter(ObjectMapper) - Constructor for class io.micronaut.pulsar.schemas.json.JacksonJsonWriter

Deprecated.

JacksonJsonWriter(JsonMapper) - Constructor for class io.micronaut.pulsar.schemas.json.JacksonJsonWriter

JSON_SCHEMA_NAME - Static variable in interface io.micronaut.pulsar.schemas.SchemaResolver

JsonSchema<T> - Class in io.micronaut.pulsar.schemas

JSON Schema to allow using ObjectMapper from Micronaut instead of shaded one in Pulsar library.

JsonSchema(SchemaInfo, SchemaReader<T>, SchemaWriter<T>) - Constructor for class io.micronaut.pulsar.schemas.JsonSchema

JsonSchemaResolver - Class in io.micronaut.pulsar.schemas.json

JSON schema resolver.

JsonSchemaResolver(JsonMapper) - Constructor for class io.micronaut.pulsar.schemas.json.JsonSchemaResolver

L

ListenerKotlinHelper - Class in io.micronaut.pulsar.processor

Kotlin helper class that bridges Java calls from Pulsar Java library into suspend calls to Kotlin.

ListenerKotlinHelper() - Constructor for class io.micronaut.pulsar.processor.ListenerKotlinHelper

M

MessageKey - Annotation Type in io.micronaut.pulsar.annotation

Parameter level annotation to indicate which parameter is bound to the Pulsar message key.

MessageListenerResolver - Interface in io.micronaut.pulsar.processor

Provides flexibility to implement MessageListener as beans while still being able to override default listener resolver for Pulsar Consumers.

MessageProperties - Annotation Type in io.micronaut.pulsar.annotation

Parameter level annotation to indicate which parameter is bound to the message properties map.

MessageSchema - Enum in io.micronaut.pulsar

Supported schema types.

O

of(Class<T>, ObjectMapper) - Static method in class io.micronaut.pulsar.schemas.JsonSchema

Deprecated.

Use JsonSchema.of(Class, JsonMapper) instead

of(Class<T>, JsonMapper) - Static method in class io.micronaut.pulsar.schemas.JsonSchema

of(Class<T>, ProtobufferCodec) - Static method in class io.micronaut.pulsar.schemas.ProtobufSchema

overrideTenantName(String) - Method in interface io.micronaut.pulsar.processor.TenantNameResolver

Enforce usage of tenant name.

P

pause(String) - Method in class io.micronaut.pulsar.processor.PulsarConsumerProcessor

pause(String) - Method in interface io.micronaut.pulsar.PulsarConsumerRegistry

PREFIX - Static variable in class io.micronaut.pulsar.config.AbstractPulsarConfiguration

The default prefix used for Pulsar configuration.

process(BeanDefinition<?>, ExecutableMethod<?, ?>) - Method in class io.micronaut.pulsar.processor.PulsarConsumerProcessor

producers - Variable in class io.micronaut.pulsar.intercept.PulsarProducerAdvice

ProducerSubscriptionFailedEvent - Class in io.micronaut.pulsar.events

Raise error event on failed producer subscription.

ProducerSubscriptionFailedEvent(String, Throwable) - Constructor for class io.micronaut.pulsar.events.ProducerSubscriptionFailedEvent

PROTOBUF_SCHEMA_NAME - Static variable in interface io.micronaut.pulsar.schemas.SchemaResolver

ProtobufReader<T> - Class in io.micronaut.pulsar.schemas.protobuf

Protobuf Schema Reader to allow using ProtobufferCodec from Micronaut.

ProtobufReader(ProtobufferCodec, Argument<T>) - Constructor for class io.micronaut.pulsar.schemas.protobuf.ProtobufReader

ProtobufSchema<T> - Class in io.micronaut.pulsar.schemas

JSON Schema to allow using ProtobufferCodec from Micronaut.

ProtobufSchema(SchemaInfo, ProtobufReader<T>, ProtobufWriter<T>) - Constructor for class io.micronaut.pulsar.schemas.ProtobufSchema

ProtobufSchemaResolver - Class in io.micronaut.pulsar.schemas.protobuf

Protobuf schema resolver.

ProtobufSchemaResolver(ProtobufferCodec) - Constructor for class io.micronaut.pulsar.schemas.protobuf.ProtobufSchemaResolver

ProtobufWriter<T> - Class in io.micronaut.pulsar.schemas.protobuf

Protobuf Schema Writer to allow using ProtobufferCodec from Micronaut.

ProtobufWriter(ProtobufferCodec) - Constructor for class io.micronaut.pulsar.schemas.protobuf.ProtobufWriter

PulsarArgumentHandler - Class in io.micronaut.pulsar.processor

Helper processor class for arguments and headers on Pulsar consumers / processors.

PulsarArgumentHandler(Argument<?>[], String) - Constructor for class io.micronaut.pulsar.processor.PulsarArgumentHandler

pulsarClient - Variable in class io.micronaut.pulsar.intercept.PulsarProducerAdvice

pulsarClient(PulsarClientConfiguration) - Method in class io.micronaut.pulsar.PulsarClientFactory

Simple factory method for building main PulsarClient that serves as a connection to Pulsar cluster.

PulsarClientConfiguration - Interface in io.micronaut.pulsar.config

Basic requirements for custom and default configuration to create Pulsar client.

PulsarClientFactory - Class in io.micronaut.pulsar

Create bean of PulsarClient type which is required by consumers and producers.

PulsarClientFactory() - Constructor for class io.micronaut.pulsar.PulsarClientFactory

PulsarConsumer - Annotation Type in io.micronaut.pulsar.annotation

Marks a method as a Pulsar Consumer.

PulsarConsumerProcessor - Class in io.micronaut.pulsar.processor

Processes beans containing methods annotated with @PulsarConsumer.

PulsarConsumerProcessor(ApplicationEventPublisher<Object>, BeanContext, PulsarClient, DefaultSchemaHandler, DefaultPulsarClientConfiguration, TopicResolver) - Constructor for class io.micronaut.pulsar.processor.PulsarConsumerProcessor

PulsarConsumerRegistry - Interface in io.micronaut.pulsar

A registry for created Pulsar consumers.

PulsarFailureEvent - Interface in io.micronaut.pulsar.events

Event raised on failure made by Pulsar client connection or reader, consumer, or producer errors.

PulsarMultitenantProducerAdvice - Class in io.micronaut.pulsar.intercept

Intercepting pulsar Producer methods.

PulsarMultitenantProducerAdvice(PulsarClient, DefaultSchemaHandler, BeanContext, ApplicationEventPublisher<ProducerSubscriptionFailedEvent>, TenantNameResolver, TopicResolver) - Constructor for class io.micronaut.pulsar.intercept.PulsarMultitenantProducerAdvice

PulsarProducer - Annotation Type in io.micronaut.pulsar.annotation

Marks a method that should produce values to Pulsar topics on call.

PulsarProducerAdvice - Class in io.micronaut.pulsar.intercept

Intercepting pulsar Producer methods.

PulsarProducerAdvice(PulsarClient, DefaultSchemaHandler, BeanContext, ApplicationEventPublisher<ProducerSubscriptionFailedEvent>) - Constructor for class io.micronaut.pulsar.intercept.PulsarProducerAdvice

Constructor for instantiating Pulsar producer advice for intercepting producer methods.

PulsarProducerClient - Annotation Type in io.micronaut.pulsar.annotation

Marks a type as a bean containing producer methods.

PulsarProducerFactory - Class in io.micronaut.pulsar

Pulsar Producer factory.

PulsarProducerFactory(PulsarClientConfiguration, TopicResolver) - Constructor for class io.micronaut.pulsar.PulsarProducerFactory

PulsarProducerRegistry - Interface in io.micronaut.pulsar

A registry of managed Producer instances key by id and type.

PulsarReader - Annotation Type in io.micronaut.pulsar.annotation

Create and inject Pulsar reader into field.

PulsarReaderAdvice - Class in io.micronaut.pulsar.intercept

Interceptor for abstract methods annotated with the PulsarReader.

PulsarReaderAdvice(BeanContext) - Constructor for class io.micronaut.pulsar.intercept.PulsarReaderAdvice

PulsarReaderClient - Annotation Type in io.micronaut.pulsar.annotation

Marks a type as a bean containing reader methods.

PulsarReaderFactory - Class in io.micronaut.pulsar

Create pulsar reader beans for fields annotated with PulsarReader.

PulsarReaderFactory(PulsarClient, DefaultSchemaHandler, TopicResolver) - Constructor for class io.micronaut.pulsar.PulsarReaderFactory

PulsarReaderRegistry - Interface in io.micronaut.pulsar

Keeps track of all created Pulsar readers.

PulsarServiceUrlProvider - Annotation Type in io.micronaut.pulsar.annotation

Marks a class that contains a method to resolve the Pulsar service url.

PulsarSubscription - Annotation Type in io.micronaut.pulsar.annotation

Mark a class that contains Pulsar consumers.

PulsarTenantDiscoveredEvent - Class in io.micronaut.pulsar.events

Simple event to publish on new tenant discovery.

PulsarTenantDiscoveredEvent(Serializable) - Constructor for class io.micronaut.pulsar.events.PulsarTenantDiscoveredEvent

R

read(byte[], int, int) - Method in class io.micronaut.pulsar.schemas.json.JacksonJsonReader

read(InputStream) - Method in class io.micronaut.pulsar.schemas.json.JacksonJsonReader

read(byte[], int, int) - Method in class io.micronaut.pulsar.schemas.protobuf.ProtobufReader

read(InputStream) - Method in class io.micronaut.pulsar.schemas.protobuf.ProtobufReader

received(Consumer, Message) - Method in class io.micronaut.pulsar.processor.DefaultListener

replaceTenantInTopic(String, String) - Static method in interface io.micronaut.pulsar.processor.TopicResolver

resolve(String) - Method in interface io.micronaut.pulsar.processor.TopicResolver

resolveTenantNameFromId(Serializable) - Method in interface io.micronaut.pulsar.processor.TenantNameResolver

Resolve tenant name as String from Serializable.

resume(String) - Method in class io.micronaut.pulsar.processor.PulsarConsumerProcessor

resume(String) - Method in interface io.micronaut.pulsar.PulsarConsumerRegistry

run(ExecutableMethod<T, R>, T, Object...) - Static method in class io.micronaut.pulsar.processor.ListenerKotlinHelper

S

SchemaResolver - Interface in io.micronaut.pulsar.schemas

SchemaResolver represents basic bean that will handle serde operations for a given type.

setAuthenticationJwt(String) - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

setDefaultMaxRetryDlq(int) - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

If not set defaults to 3.

setDefaultTenant(String) - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

Use in combination with ${tenant} placeholder in PulsarConsumer.topic(), PulsarConsumer.topics(), PulsarConsumer.topicsPattern(), PulsarReader.topic(), PulsarProducer.topic() to avoid hardcoding tenant name into source code through mentioned annotations.

setIoThreads(Integer) - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

setListenerThreads(Integer) - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

setOauthAudience(String) - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

setOauthCredentialsUrl(URL) - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

setOauthIssuerUrl(URL) - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

setServiceUrl(String) - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

setShutdownOnSubscriberError(Boolean) - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

setSslProvider(String) - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

Defaults to default JVM provider.

setTlsAllowInsecureConnection(Boolean) - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

setTlsCertFilePath(String) - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

setTlsCiphers(Set<String>) - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

setTlsProtocols(Set<String>) - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

setTlsTrustStorePath(String) - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

setTlsVerifyHostname(Boolean) - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

setUseDeadLetterQueue(Boolean) - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration

If not set defaults to true which means that after max number of retries failed message is sent to DLQ and won't be resent again.

simpleSchemaResolver - Variable in class io.micronaut.pulsar.intercept.PulsarProducerAdvice

size() - Method in class io.micronaut.pulsar.processor.PulsarArgumentHandler

T

TENANT_NAME_VALIDATOR - Static variable in class io.micronaut.pulsar.config.AbstractPulsarConfiguration

TenantNameResolver - Interface in io.micronaut.pulsar.processor

Resolve tenant ID class representation to Apache Pulsar tenant name (as String).

TOPIC_NAME_PATTERN_VALIDATOR - Static variable in class io.micronaut.pulsar.config.AbstractPulsarConfiguration

Regex for validating topic pattern.

TOPIC_NAME_VALIDATOR - Static variable in class io.micronaut.pulsar.config.AbstractPulsarConfiguration

Regex for validating topic name.

topicResolver - Variable in class io.micronaut.pulsar.processor.PulsarConsumerProcessor

TopicResolver - Interface in io.micronaut.pulsar.processor

Process input string to determine real topic name for Apache Pulsar.

TopicResolver.TopicResolved - Class in io.micronaut.pulsar.processor

Simple container class for describing resolved topics.

V

valueOf(String) - Static method in enum io.micronaut.pulsar.MessageSchema

Returns the enum constant of this type with the specified name.

values() - Static method in enum io.micronaut.pulsar.MessageSchema

Returns an array containing the constants of this enum type, in the order they are declared.

W

write(T) - Method in class io.micronaut.pulsar.schemas.json.JacksonJsonWriter

write(Object) - Method in class io.micronaut.pulsar.schemas.protobuf.ProtobufWriter

A B C D E F G H I J L M O P R S T V W