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 listener.
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
 
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.
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.config.PulsarListenerEndpointAdapter
 
isBatchListener() - Method in class org.springframework.pulsar.listener.PulsarContainerProperties
 
isConsumerRecords() - Method in class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter
 
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
 
isFluxListener() - Method in class org.springframework.pulsar.reactive.config.ReactivePulsarListenerEndpointAdapter
 
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.
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
 
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.function.PulsarFunctionAdministration
 
isRunning() - Method in class org.springframework.pulsar.listener.AbstractPulsarMessageListenerContainer
 
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