A C D G 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

C

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

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>, SchemaResolver, String, Class<T>) - Method in class io.micronaut.pulsar.PulsarProducerFactory

Simple factory method for producing Pulsar Producer beans.

createReader(InjectionPoint<?>) - Method in class io.micronaut.pulsar.PulsarReaderFactory

Create Pulsar Reader for given injection point if missing.

D

decideSchema(AnnotationValue<?>, Class<?>) - Method in class io.micronaut.pulsar.processor.SchemaResolver

Resolve which schema to use.

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) - 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.

G

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

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

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

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

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

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

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

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

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

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.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.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.

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

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

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

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

I

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

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 Pulsar consumers, readers, and producers.

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

Interceptors for methods annotated with Pulsar annotations.

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

Pulsar annotations processors.

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.

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

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

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

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

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

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

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.

MessageSchema - Enum in io.micronaut.pulsar

Supported schema types.

O

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

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

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

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, BeanContext, PulsarClient, SchemaResolver, DefaultPulsarClientConfiguration) - 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.

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, SchemaResolver, BeanContext, ApplicationEventPublisher) - Constructor for class io.micronaut.pulsar.intercept.PulsarProducerAdvice

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(BeanContext, SchemaResolver, PulsarClient) - 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.

PulsarReaderFactory - Class in io.micronaut.pulsar

Create pulsar reader beans for fields annotated with PulsarReader.

PulsarReaderFactory(PulsarClient, SchemaResolver) - 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.

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

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

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 - Class in io.micronaut.pulsar.processor

Message type resolver for Pulsar schema.

SchemaResolver(ObjectMapper) - Constructor for class io.micronaut.pulsar.processor.SchemaResolver

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.

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.

T

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.

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

A C D G I J L M O P R S T V W