Index (pulsar-parent 2.2.0 API)

A B C D E F G H I J K L M O P R S T V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

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
ackGroupTimeout() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarSubscription: By default it will use PulsarConsumer builder default values.
ackTimeout() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarConsumer: By default, it will use default value of ConsumerBuilder which is disabled and no redelivery happens unless consumer crashed.
applicationEventPublisher - Variable in class io.micronaut.pulsar.intercept.PulsarProducerAdvice
argumentOrder() - Method in class io.micronaut.pulsar.processor.PulsarArgumentHandler
autoUpdatePartition() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarProducer
AVRO - Enum constant in enum class io.micronaut.pulsar.MessageSchema: An Apache Avro schema.
AVRO_SCHEMA_NAME - Static variable in interface io.micronaut.pulsar.schemas.SchemaResolver
AvroSchemaResolver - Class in io.micronaut.pulsar.schemas.avro: AVRO schema resolver.
AvroSchemaResolver() - Constructor for class io.micronaut.pulsar.schemas.avro.AvroSchemaResolver

B

batching() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarProducer
batchingMaxBytes() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarProducer: Default 128KB.
batchingMaxMessages() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarProducer
beanContext - Variable in class io.micronaut.pulsar.intercept.PulsarProducerAdvice
beanContext - Variable in class io.micronaut.pulsar.intercept.PulsarReaderAdvice
blockQueue() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarProducer
bodyType(Argument<?>) - Static method in class io.micronaut.pulsar.processor.DefaultSchemaHandler
BOOL - Enum constant in enum class io.micronaut.pulsar.MessageSchema: A binary value.
BYTEBUFFER - Enum constant in enum class io.micronaut.pulsar.MessageSchema: Effectively a `BYTES` schema.
BYTES - Enum constant in enum class io.micronaut.pulsar.MessageSchema: A sequence of 8-bit unsigned bytes.

C

chunking() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarProducer: If this is enabled batching should be disabled.
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
compressionType() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarProducer
consumerExists(String) - Method in class io.micronaut.pulsar.processor.PulsarConsumerProcessor
consumerExists(String) - Method in interface io.micronaut.pulsar.PulsarConsumerRegistry
consumerName() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarConsumer
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
conversionService - Variable in class io.micronaut.pulsar.intercept.PulsarProducerAdvice
conversionService - Variable in class io.micronaut.pulsar.intercept.PulsarReaderAdvice
createProducer(PulsarClient, AnnotationValue<PulsarProducer>, Argument<?>[], DefaultSchemaHandler, String) - Method in class io.micronaut.pulsar.PulsarProducerFactory: Simple factory method for producing Pulsar Producer beans.

D

DATE - Enum constant in enum class io.micronaut.pulsar.MessageSchema: A schema for `java.util.Date` or `java.sql.Date`.
deadLetterTopic() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarConsumer: Default is fallback to Pulsar Client Java library.
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, 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
DOUBLE - Enum constant in enum class io.micronaut.pulsar.MessageSchema: A double-precision (64-bit) IEEE 754 floating-point number.

E

encryptionKey() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarProducer
extractTopic(AnnotationValue<?>, String) - Static method in interface io.micronaut.pulsar.processor.TopicResolver

F

FLOAT - Enum constant in enum class io.micronaut.pulsar.MessageSchema: A single precision (32-bit) IEEE 754 floating-point number.
forArgument(Class<T>) - Method in class io.micronaut.pulsar.schemas.avro.AvroSchemaResolver
forArgument(Class<T>) - Method in class io.micronaut.pulsar.schemas.json.JsonSchemaResolver
forArgument(Class<T>) - Method in class io.micronaut.pulsar.schemas.protobuf.ProtobufSchemaResolver
forArgument(Class<T>) - 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: Useful for avoiding hard coding tenant name into every annotation value for producers, consumers, or readers.
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 class 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: Optional provider for Pulsar services URL.
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: Ciphers like TLS_RSA_WITH_AES_256_GCM_SHA384, TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256.
getTlsProtocols() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration
getTlsProtocols() - Method in interface io.micronaut.pulsar.config.PulsarClientConfiguration: Protocols like TLSv1.3, TLSv1.2.
getTlsTrustStorePassword() - Method in class io.micronaut.pulsar.config.DefaultPulsarClientConfiguration
getTlsTrustStorePassword() - 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: Useful in development environment for using with local host or such.
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
hashingScheme() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarProducer
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

initialSequenceId() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarProducer
INT16 - Enum constant in enum class io.micronaut.pulsar.MessageSchema: A 16-bit signed integer.
INT32 - Enum constant in enum class io.micronaut.pulsar.MessageSchema: A 32-bit signed integer.
INT64 - Enum constant in enum class io.micronaut.pulsar.MessageSchema: A 64-bit signed integer.
INT8 - Enum constant in enum class io.micronaut.pulsar.MessageSchema: Effectively a `BYTES` schema of a single byte.
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.avro - package io.micronaut.pulsar.schemas.avro
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

JSON - Enum constant in enum class io.micronaut.pulsar.MessageSchema: A schema for JSON data.
JSON_SCHEMA_NAME - Static variable in interface io.micronaut.pulsar.schemas.SchemaResolver
JsonReader<T> - Class in io.micronaut.pulsar.schemas.json: JSON Schema Reader to allow using JsonMapper from Micronaut instead of shaded one in Pulsar library.
JsonReader(JsonMapper, Class<T>) - Constructor for class io.micronaut.pulsar.schemas.json.JsonReader
JsonSchema<T> - Class in io.micronaut.pulsar.schemas.json: JSON Schema to allow using JsonMapper from Micronaut instead of shaded one in Pulsar library.
JsonSchema(SchemaInfo, SchemaReader<T>, SchemaWriter<T>) - Constructor for class io.micronaut.pulsar.schemas.json.JsonSchema
JsonSchemaResolver - Class in io.micronaut.pulsar.schemas.json: JSON schema resolver.
JsonSchemaResolver(JsonMapper) - Constructor for class io.micronaut.pulsar.schemas.json.JsonSchemaResolver
JsonWriter<T> - Class in io.micronaut.pulsar.schemas.json: JSON Schema Writer to allow using JsonMapper from Micronaut instead of shaded one in Pulsar library.
JsonWriter(JsonMapper) - Constructor for class io.micronaut.pulsar.schemas.json.JsonWriter

K

keyEncoding() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarConsumer: Ignored if annotated method does not contain parameter annotated with MessageKey.
keyEncoding() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarProducer: If no MessageKey annotated method argument is detected this attribute is ignored and message is treated as simple - without a key.
keyEncoding() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarReader: If argument annotated with PulsarReader is of KeyValue it's possible to choose where to get the message key from.
keySchema() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarConsumer: Ignored if PulsarConsumer.keyEncoding() is KeyValueEncodingType.INLINE or if MessageKey is missing on one of the attributes of the annotated method.
keySchema() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarProducer
keySchema() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarReader: If argument annotated with PulsarReader is of KeyValue it's possible to choose different schema for key transfer.

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

maxRetriesBeforeDlq() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarConsumer
MessageKey - Annotation Interface 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 Interface in io.micronaut.pulsar.annotation: Parameter level annotation to indicate which parameter is bound to the message properties map.
messageRoutingMode() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarProducer
MessageSchema - Enum Class in io.micronaut.pulsar: Supported schema types.
multiSchema() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarProducer

O

of(Class<T>, JsonMapper) - Static method in class io.micronaut.pulsar.schemas.json.JsonSchema
of(Class<T>, ProtobufferCodec) - Static method in class io.micronaut.pulsar.schemas.protobuf.ProtobufSchema
overrideTenantName(String) - Method in interface io.micronaut.pulsar.processor.TenantNameResolver: Enforce usage of tenant name.

P

patternAutoDiscoveryPeriod() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarConsumer: Used in combination with PulsarConsumer.topicsPattern().
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.
priorityLevel() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarConsumer: By default, no priority is set.
process(BeanDefinition<?>, ExecutableMethod<?, ?>) - Method in class io.micronaut.pulsar.processor.PulsarConsumerProcessor
producerName() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarProducer
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 - Enum constant in enum class io.micronaut.pulsar.MessageSchema: A schema for Protocol Buffer generated messages.
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.protobuf: JSON Schema to allow using ProtobufferCodec from Micronaut.
ProtobufSchema(SchemaInfo, ProtobufReader<T>, ProtobufWriter<T>) - Constructor for class io.micronaut.pulsar.schemas.protobuf.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, EventLoopGroup) - Method in class io.micronaut.pulsar.PulsarClientFactory: Simple factory method for building main PulsarClient that serves as a connection to Pulsar cluster.
pulsarClientConfiguration - Variable in class io.micronaut.pulsar.processor.PulsarConsumerProcessor
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 Interface 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>, TopicResolver, ConversionService) - Constructor for class io.micronaut.pulsar.intercept.PulsarMultitenantProducerAdvice
PulsarProducer - Annotation Interface 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>, ConversionService) - Constructor for class io.micronaut.pulsar.intercept.PulsarProducerAdvice: Constructor for instantiating Pulsar producer advice for intercepting producer methods.
PulsarProducerClient - Annotation Interface in io.micronaut.pulsar.annotation: Marks a type as a bean containing producer methods.
PulsarProducerFactory - Class in io.micronaut.pulsar: Pulsar Producer factory.
PulsarProducerFactory(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 Interface 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, ConversionService) - Constructor for class io.micronaut.pulsar.intercept.PulsarReaderAdvice
PulsarReaderClient - Annotation Interface 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 Interface in io.micronaut.pulsar.annotation: Marks a class that contains a method to resolve the Pulsar service url.
PulsarSubscription - Annotation Interface 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.JsonReader
read(byte[], int, int) - Method in class io.micronaut.pulsar.schemas.protobuf.ProtobufReader
read(InputStream) - Method in class io.micronaut.pulsar.schemas.json.JsonReader
read(InputStream) - Method in class io.micronaut.pulsar.schemas.protobuf.ProtobufReader
readerName() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarReader
readTimeout() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarReader: Ignored on Reader.readNextAsync().
received(Consumer, Message) - Method in class io.micronaut.pulsar.processor.DefaultListener
receiverQueueSize() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarConsumer
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

schema() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarConsumer: Defaults to MessageSchema.BYTES as default value for Pulsar Schema is byte[].
schema() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarProducer
schema() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarReader: Defaults to MessageSchema.BYTES as default value for Pulsar Schema is byte[].
SchemaResolver - Interface in io.micronaut.pulsar.schemas: SchemaResolver represents basic bean that will handle serde operations for a given type.
sendBefore() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarProducer: Defaults to false.
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 16 (Pulsar library default).
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
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
setTlsTrustStorePassword(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
startMessageLatest() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarReader
STRING - Enum constant in enum class io.micronaut.pulsar.MessageSchema: A Unicode character sequence.
subscribeAsync() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarConsumer: By default, consumer should subscribe in non-blocking manner using default CompletableFuture of ConsumerBuilder.subscribeAsync().
subscribeAsync() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarReader: By default, reader should subscribe in non-blocking manner using default CompletableFuture of ConsumerBuilder.subscribeAsync().
subscription() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarConsumer
subscriptionName() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarReader
subscriptionName() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarSubscription: If not set, UUID will be generated as subscription name to avoid collisions if consumer type is Exclusive.
subscriptionTopicsMode() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarConsumer: Ignored if topics() attribute is set.
subscriptionType() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarConsumer
subscriptionType() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarSubscription: By default Exclusive.

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).
TIME - Enum constant in enum class io.micronaut.pulsar.MessageSchema: A schema for `java.sql.Time`.
timeoutUnit() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarReader: Ignored on Reader.readNextAsync() or if PulsarReader.readTimeout() is 0.
TIMESTAMP - Enum constant in enum class io.micronaut.pulsar.MessageSchema: A schema for `java.sql.Timestamp`.
topic() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarConsumer: Has precedence over PulsarConsumer.topics() and PulsarConsumer.topicsPattern().
topic() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarProducer
topic() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarReader: Only single topic subscription possible for readers.
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.
topics() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarConsumer: Has precedence over topicPattern.
topicsPattern() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarConsumer: Ignored if topics attribute is set.

V

value() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarConsumer
value() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarProducer
value() - Element in annotation interface io.micronaut.pulsar.annotation.PulsarReader
valueOf(String) - Static method in enum class io.micronaut.pulsar.MessageSchema: Returns the enum constant of this class with the specified name.
values() - Static method in enum class io.micronaut.pulsar.MessageSchema: Returns an array containing the constants of this enum class, in the order they are declared.

W

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

A B C D E F G H I J K L M O P R S T V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form