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.reactive.config.annotation.ReactivePulsarListener

The unique identifier of the container for this listener.

immediate - Enum constant in enum class org.springframework.pulsar.autoconfigure.PulsarReactiveProperties.SchedulerType

The reactor.core.scheduler.ImmediateScheduler.

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(ConcurrentPulsarMessageListenerContainer<T>, PulsarListenerEndpoint) - Method in class org.springframework.pulsar.config.ConcurrentPulsarListenerContainerFactory

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.

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

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(Object, Message<?>, Consumer<V>, Acknowledgement) - Method in class org.springframework.pulsar.listener.adapter.PulsarMessagingMessageListenerAdapter

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

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

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

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

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

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

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

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

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

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.

isObservationsEnabled() - Method in class org.springframework.pulsar.autoconfigure.PulsarProperties.Listener

isObservationsEnabled() - Method in class org.springframework.pulsar.autoconfigure.PulsarProperties.Template

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

Checks if the topic is partitioned.

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

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

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

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

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

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

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

isTlsAllowInsecureConnection() - Method in class org.springframework.pulsar.autoconfigure.PulsarProperties.Admin

isTlsHostnameVerificationEnable() - Method in class org.springframework.pulsar.autoconfigure.PulsarProperties.Admin

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

isUseKeyStoreTls() - Method in class org.springframework.pulsar.autoconfigure.PulsarProperties.Admin

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