Index

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

I

id() - Element in annotation interface org.springframework.pulsar.annotation.PulsarListener

The unique identifier of the container for this listener.

id() - Element in annotation interface org.springframework.pulsar.annotation.PulsarReader

The unique identifier of the container for this reader.

id() - Element in annotation interface org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListener

The unique identifier of the container for this listener.

ifResolved(Consumer<? super T>) - Method in class org.springframework.pulsar.core.Resolved

Performs the given action with the resolved value if a value was resolved and no exception occurred.

ifResolvedOrElse(Consumer<? super T>, Consumer<RuntimeException>) - Method in class org.springframework.pulsar.core.Resolved

Performs the given action with the resolved value if a non-null value was resolved and no exception occurred.

inboundPatterns(String...) - Method in class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper.JsonPulsarHeaderMapperBuilder

Adds to the list of patterns to be used for inbound header matching.

INDEX - Static variable in class org.springframework.pulsar.support.PulsarHeaders

Message index if available.

initializeContainer(C, PulsarListenerEndpoint) - Method in class org.springframework.pulsar.config.AbstractPulsarListenerContainerFactory

initializeContainer(C, PulsarReaderEndpoint<PulsarMessageReaderContainer>) - Method in class org.springframework.pulsar.config.AbstractPulsarReaderContainerFactory

initializeContainer(ConcurrentPulsarMessageListenerContainer<T>, PulsarListenerEndpoint) - Method in class org.springframework.pulsar.config.ConcurrentPulsarListenerContainerFactory

initializeContainer(DefaultPulsarMessageReaderContainer<T>, PulsarReaderEndpoint<PulsarMessageReaderContainer>) - Method in class org.springframework.pulsar.config.DefaultPulsarReaderContainerFactory

INSTANCE - Static variable in class org.springframework.pulsar.observation.DefaultPulsarListenerObservationConvention

A singleton instance of the convention.

INSTANCE - Static variable in class org.springframework.pulsar.observation.DefaultPulsarTemplateObservationConvention

A singleton instance of the convention.

INSTANCE - Static variable in class org.springframework.pulsar.support.JavaUtils

The singleton instance of this utility class.

INSTANCE - Static variable in class org.springframework.pulsar.support.PulsarNull

Singleton instance.

inTransaction(PulsarClient) - Static method in class org.springframework.pulsar.transaction.PulsarTransactionUtils

Determine if the given pulsar client is currently participating in an active transaction.

invalidateAll(BiConsumer<K, V>) - Method in interface org.springframework.pulsar.cache.provider.CacheProvider

Discards all entries in the cache and calls the onInvalidateEntry callback (if provided) for each entry.

invalidateAll(BiConsumer<K, V>) - Method in class org.springframework.pulsar.cache.provider.caffeine.CaffeineCacheProvider

InvocationResult - Class in org.springframework.pulsar.listener.adapter

The result of a method invocation.

InvocationResult(Object, Expression, boolean) - Constructor for class org.springframework.pulsar.listener.adapter.InvocationResult

invoke(Object, Consumer<V>, Message<?>, Acknowledgement) - Method in class org.springframework.pulsar.listener.adapter.PulsarBatchMessagesToSpringMessageListenerAdapter

invoke(Message<?>, Object...) - Method in class org.springframework.pulsar.listener.adapter.DelegatingInvocableHandler

Invoke the method with the given message.

invoke(Message<?>, Object...) - Method in class org.springframework.pulsar.listener.adapter.HandlerAdapter

invokeHandler(Message<?>, Object...) - Method in class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

isAutoStartup() - Method in class org.springframework.pulsar.config.GenericListenerEndpointRegistry

isAutoStartup() - Method in class org.springframework.pulsar.config.GenericReaderEndpointRegistry

isAutoStartup() - Method in class org.springframework.pulsar.listener.AbstractPulsarMessageListenerContainer

isAutoStartup() - Method in class org.springframework.pulsar.reactive.listener.DefaultReactivePulsarMessageListenerContainer

isAutoStartup() - Method in class org.springframework.pulsar.reader.AbstractPulsarMessageReaderContainer

isBatchListener() - Method in class org.springframework.pulsar.config.AbstractPulsarListenerEndpoint

isBatchListener() - Method in interface org.springframework.pulsar.config.PulsarListenerEndpoint

isBatchListener() - Method in class org.springframework.pulsar.listener.PulsarContainerProperties

isConsumerRecords() - Method in class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

isEmptyPayload(Object) - Method in class org.springframework.pulsar.annotation.PulsarNullAwarePayloadArgumentResolver

isEnabled() - Method in class org.springframework.pulsar.core.TransactionProperties

isExistingTransaction(Object) - Method in class org.springframework.pulsar.transaction.PulsarTransactionManager

isFlux(Type) - Method in class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

Determine if the type is a reactive Flux.

isFlux(Type) - Method in class org.springframework.pulsar.reactive.listener.adapter.PulsarReactiveMessagingMessageListenerAdapter

Determine if the type is a reactive Flux.

isFluxListener() - Method in class org.springframework.pulsar.reactive.config.AbstractReactivePulsarListenerEndpoint

isFluxListener() - Method in interface org.springframework.pulsar.reactive.config.ReactivePulsarListenerEndpoint

isHeaderFound() - Method in class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

isJacksonPresent() - Static method in class org.springframework.pulsar.support.header.JacksonUtils

Determines if the Jackson JSON processor is on the classpath.

isLambda(Class<?>) - Method in class org.springframework.pulsar.support.JavaUtils

Determine if the specified class is a Lambda.

isMessageList() - Method in class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

isMessageReturnType() - Method in class org.springframework.pulsar.listener.adapter.InvocationResult

isMultipleMessageType(Type) - Method in class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

Determines if a type is one that holds multiple messages.

isMultipleMessageType(Type) - Method in class org.springframework.pulsar.reactive.listener.adapter.PulsarReactiveMessagingMessageListenerAdapter

Determines if a type is one that holds multiple messages.

isNegated() - Method in interface org.springframework.pulsar.support.header.PulsarHeaderMatcher

Determine if this matcher is a negative matcher where a match means that the header should not be included.

isNegated() - Method in class org.springframework.pulsar.support.header.PulsarHeaderMatcher.NeverMatch

isNegated() - Method in class org.springframework.pulsar.support.header.PulsarHeaderMatcher.PatternMatch

isObservationEnabled() - Method in class org.springframework.pulsar.listener.PulsarContainerProperties

isPartitioned() - Method in record class org.springframework.pulsar.core.PulsarTopic

Checks if the topic is partitioned.

isPaused() - Method in class org.springframework.pulsar.listener.AbstractPulsarMessageListenerContainer

isPulsarMessageList() - Method in class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

isRequired() - Method in class org.springframework.pulsar.core.TransactionProperties

isRunning() - Method in class org.springframework.pulsar.config.GenericListenerEndpointRegistry

isRunning() - Method in class org.springframework.pulsar.config.GenericReaderEndpointRegistry

isRunning() - Method in class org.springframework.pulsar.core.CachingPulsarProducerFactory

isRunning() - Method in class org.springframework.pulsar.function.PulsarFunctionAdministration

isRunning() - Method in class org.springframework.pulsar.listener.AbstractPulsarMessageListenerContainer

isRunning() - Method in class org.springframework.pulsar.reactive.core.DefaultReactivePulsarSenderFactory

isRunning() - Method in class org.springframework.pulsar.reactive.listener.DefaultReactivePulsarMessageListenerContainer

isRunning() - Method in class org.springframework.pulsar.reader.AbstractPulsarMessageReaderContainer

isSimpleExtraction() - Method in class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

isSpringMessage() - Method in class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

isSpringMessageFlux() - Method in class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

isUseKeyOrderedProcessing() - Method in class org.springframework.pulsar.reactive.listener.ReactivePulsarContainerProperties

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