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

P

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

The reactor.core.scheduler.ParallelScheduler.

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

postProcessAfterInitialization(Object, String) - Method in class org.springframework.pulsar.annotation.PulsarListenerAnnotationBeanPostProcessor

postProcessAfterInitialization(Object, String) - Method in class org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListenerAnnotationBeanPostProcessor

postProcessBeforeInitialization(Object, String) - Method in class org.springframework.pulsar.annotation.PulsarListenerAnnotationBeanPostProcessor

postProcessBeforeInitialization(Object, String) - Method in class org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListenerAnnotationBeanPostProcessor

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

The prefix for Pulsar headers.

processListener(MethodPulsarListenerEndpoint<?>, PulsarListener, Object, String, String[], String) - Method in class org.springframework.pulsar.annotation.PulsarListenerAnnotationBeanPostProcessor

processListener(MethodReactivePulsarListenerEndpoint<?>, ReactivePulsarListener, Object, String, String[], String) - Method in class org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListenerAnnotationBeanPostProcessor

processPulsarListener(PulsarListener, Method, Object, String) - Method in class org.springframework.pulsar.annotation.PulsarListenerAnnotationBeanPostProcessor

processReactivePulsarListener(ReactivePulsarListener, Method, Object, String) - Method in class org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListenerAnnotationBeanPostProcessor

Producer() - Constructor for class org.springframework.pulsar.autoconfigure.PulsarProperties.Producer

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

Producer name.

ProducerBuilderCustomizer<T> - Interface in org.springframework.pulsar.core

The interface to customize a ProducerBuilder.

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

Pulsar consumer properties; they will supersede any properties with the same name defined in the consumer factory (if the consumer factory supports property overrides).

properties() - Method in class org.springframework.pulsar.observation.PulsarMessageSenderContext.MessageHolder

properties() - Method in class org.springframework.pulsar.observation.PulsarMessageSenderContext

property(String, String) - Method in class org.springframework.pulsar.observation.PulsarMessageSenderContext.MessageHolder

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

Message publish time (long).

PULSAR_LISTENER_ANNOTATION_PROCESSOR_BEAN_NAME - Static variable in class org.springframework.pulsar.config.PulsarListenerBeanNames

The bean name of the internally managed Pulsar listener annotation processor.

PULSAR_LISTENER_ENDPOINT_REGISTRY_BEAN_NAME - Static variable in class org.springframework.pulsar.config.PulsarListenerBeanNames

The bean name of the internally managed Pulsar listener endpoint registry.

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

The prefix for the message.

PulsarAcknowledgingMessageListener<T> - Interface in org.springframework.pulsar.listener

Message listener for manually acknowledging messages.

pulsarAdministration() - Method in class org.springframework.pulsar.autoconfigure.PulsarAutoConfiguration

PulsarAdministration - Class in org.springframework.pulsar.core

An administration class that delegates to PulsarAdmin to create and manage topics defined in the application context.

PulsarAdministration(Map<String, Object>) - Constructor for class org.springframework.pulsar.core.PulsarAdministration

Construct a PulsarAdministration instance using the given configuration for the underlying PulsarAdmin.

PulsarAdministration(PulsarAdminBuilder) - Constructor for class org.springframework.pulsar.core.PulsarAdministration

Construct a PulsarAdministration instance using the given builder for the underlying PulsarAdmin.

PulsarAdministrationOperations - Interface in org.springframework.pulsar.core

The Pulsar administration contract.

PulsarAnnotationDrivenConfiguration - Class in org.springframework.pulsar.autoconfigure

Configuration for Pulsar annotation-driven support.

PulsarAnnotationDrivenConfiguration(PulsarProperties) - Constructor for class org.springframework.pulsar.autoconfigure.PulsarAnnotationDrivenConfiguration

PulsarAutoConfiguration - Class in org.springframework.pulsar.autoconfigure

Auto-configuration for Apache Pulsar.

PulsarAutoConfiguration(PulsarProperties) - Constructor for class org.springframework.pulsar.autoconfigure.PulsarAutoConfiguration

PulsarBatchAcknowledgingMessageListener<T> - Interface in org.springframework.pulsar.listener

Batch message listener that allows manual acknowledgment.

PulsarBatchListenerFailedException - Exception in org.springframework.pulsar.listener

Batch message listeners should throw this exception in the event of an error.

PulsarBatchListenerFailedException(String, Throwable, Message<?>) - Constructor for exception org.springframework.pulsar.listener.PulsarBatchListenerFailedException

PulsarBatchListenerFailedException(String, Message<?>) - Constructor for exception org.springframework.pulsar.listener.PulsarBatchListenerFailedException

PulsarBatchMessageConverter<T> - Interface in org.springframework.pulsar.support.converter

Pulsar batch message converter strategy.

PulsarBatchMessageListener<T> - Interface in org.springframework.pulsar.listener

Batch message listener.

PulsarBatchMessagingMessageConverter<T> - Class in org.springframework.pulsar.support.converter

Batch records message converter.

PulsarBatchMessagingMessageConverter() - Constructor for class org.springframework.pulsar.support.converter.PulsarBatchMessagingMessageConverter

PulsarBatchMessagingMessageConverter(PulsarRecordMessageConverter<T>) - Constructor for class org.springframework.pulsar.support.converter.PulsarBatchMessagingMessageConverter

PulsarBatchMessagingMessageListenerAdapter<V> - Class in org.springframework.pulsar.listener.adapter

A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive batches of messages.

PulsarBatchMessagingMessageListenerAdapter(Object, Method) - Constructor for class org.springframework.pulsar.listener.adapter.PulsarBatchMessagingMessageListenerAdapter

PulsarBootstrapConfiguration - Class in org.springframework.pulsar.annotation

An ImportBeanDefinitionRegistrar class that registers a PulsarListenerAnnotationBeanPostProcessor bean capable of processing Spring's @PulsarListener annotation.

PulsarBootstrapConfiguration() - Constructor for class org.springframework.pulsar.annotation.PulsarBootstrapConfiguration

pulsarClientConfiguration() - Method in class org.springframework.pulsar.autoconfigure.PulsarAutoConfiguration

PulsarClientConfiguration - Class in org.springframework.pulsar.config

Configuration for the Pulsar client.

PulsarClientConfiguration() - Constructor for class org.springframework.pulsar.config.PulsarClientConfiguration

PulsarClientConfiguration(Map<String, Object>) - Constructor for class org.springframework.pulsar.config.PulsarClientConfiguration

pulsarClientFactoryBean(PulsarClientConfiguration) - Method in class org.springframework.pulsar.autoconfigure.PulsarAutoConfiguration

PulsarClientFactoryBean - Class in org.springframework.pulsar.config

FactoryBean implementation for the PulsarClient.

PulsarClientFactoryBean(PulsarClientConfiguration) - Constructor for class org.springframework.pulsar.config.PulsarClientFactoryBean

pulsarConsumerErrorHandler - Variable in class org.springframework.pulsar.listener.AbstractPulsarMessageListenerContainer

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

The bean name or a 'SpEL' expression that resolves to a PulsarConsumerErrorHandler which is used as a Spring provided mechanism to handle errors from processing the message.

PulsarConsumerErrorHandler<T> - Interface in org.springframework.pulsar.listener

Contract for consumer error handling through the message listener container.

pulsarConsumerFactory(PulsarClient) - Method in class org.springframework.pulsar.autoconfigure.PulsarAutoConfiguration

PulsarConsumerFactory<T> - Interface in org.springframework.pulsar.core

Pulsar consumer factory interface.

PulsarContainerProperties - Class in org.springframework.pulsar.listener

Contains runtime properties for a listener container.

PulsarContainerProperties(String) - Constructor for class org.springframework.pulsar.listener.PulsarContainerProperties

PulsarContainerProperties(String...) - Constructor for class org.springframework.pulsar.listener.PulsarContainerProperties

PulsarDeadLetterPublishingRecoverer<T> - Class in org.springframework.pulsar.listener

PulsarMessageRecoverer implementation that is capable of recovering the message by publishing the failed record to a DLT - Dead Letter Topic.

PulsarDeadLetterPublishingRecoverer(PulsarOperations<T>) - Constructor for class org.springframework.pulsar.listener.PulsarDeadLetterPublishingRecoverer

PulsarDeadLetterPublishingRecoverer(PulsarOperations<T>, BiFunction<Consumer<?>, Message<?>, String>) - Constructor for class org.springframework.pulsar.listener.PulsarDeadLetterPublishingRecoverer

PulsarEvent - Class in org.springframework.pulsar.event

Base class for events.

PulsarEvent(Object, Object) - Constructor for class org.springframework.pulsar.event.PulsarEvent

PulsarException - Exception in org.springframework.pulsar

Spring Pulsar specific NestedRuntimeException implementation.

PulsarException(String) - Constructor for exception org.springframework.pulsar.PulsarException

PulsarException(String, Throwable) - Constructor for exception org.springframework.pulsar.PulsarException

PulsarHeaders - Class in org.springframework.pulsar.support

Pulsar specific message headers.

PulsarHeaders() - Constructor for class org.springframework.pulsar.support.PulsarHeaders

PulsarListener - Annotation Interface in org.springframework.pulsar.annotation

Annotation that marks a method to be the target of a Pulsar message listener on the specified topics.

PulsarListenerAnnotationBeanPostProcessor<V> - Class in org.springframework.pulsar.annotation

Bean post-processor that registers methods annotated with PulsarListener to be invoked by a Pulsar message listener container created under the covers by a PulsarListenerContainerFactory according to the parameters of the annotation.

PulsarListenerAnnotationBeanPostProcessor() - Constructor for class org.springframework.pulsar.annotation.PulsarListenerAnnotationBeanPostProcessor

PulsarListenerAnnotationBeanPostProcessor.AnnotationEnhancer - Interface in org.springframework.pulsar.annotation

PulsarListenerBeanNames - Class in org.springframework.pulsar.config

Constants for bean names that need to be accessed in multiple places by name.

PulsarListenerBeanNames() - Constructor for class org.springframework.pulsar.config.PulsarListenerBeanNames

PulsarListenerConfigurationSelector - Class in org.springframework.pulsar.annotation

A DeferredImportSelector implementation with the lowest order to import PulsarBootstrapConfiguration as late as possible.

PulsarListenerConfigurationSelector() - Constructor for class org.springframework.pulsar.annotation.PulsarListenerConfigurationSelector

PulsarListenerConfigurer - Interface in org.springframework.pulsar.annotation

Optional interface to be implemented by Spring managed bean willing to customize how Pulsar listener endpoints are configured.

PulsarListenerContainerFactory - Interface in org.springframework.pulsar.config

Factory for Pulsar message listener containers.

PulsarListenerContainerRegistry - Interface in org.springframework.pulsar.listener

A registry for listener containers.

PulsarListenerEndpoint - Interface in org.springframework.pulsar.config

Model for a Pulsar listener endpoint.

PulsarListenerEndpointAdapter - Class in org.springframework.pulsar.config

Adapter to avoid having to implement all methods.

PulsarListenerEndpointAdapter() - Constructor for class org.springframework.pulsar.config.PulsarListenerEndpointAdapter

PulsarListenerEndpointRegistrar - Class in org.springframework.pulsar.config

Helper bean for registering ListenerEndpoint with a ListenerEndpointRegistry.

PulsarListenerEndpointRegistrar(Class<? extends ListenerContainerFactory>) - Constructor for class org.springframework.pulsar.config.PulsarListenerEndpointRegistrar

PulsarListenerEndpointRegistry - Class in org.springframework.pulsar.config

Creates the necessary PulsarMessageListenerContainer instances for the registered endpoints.

PulsarListenerEndpointRegistry() - Constructor for class org.springframework.pulsar.config.PulsarListenerEndpointRegistry

PulsarListenerObservation - Enum Class in org.springframework.pulsar.observation

An Observation for a PulsarListener.

PulsarListenerObservation.ListenerLowCardinalityTags - Enum Class in org.springframework.pulsar.observation

Low cardinality tags.

PulsarListenerObservationConvention - Interface in org.springframework.pulsar.observation

ObservationConvention for Pulsar listener key values.

PulsarListeners - Annotation Interface in org.springframework.pulsar.annotation

Container annotation that aggregates several PulsarListener annotations.

PulsarMessageHeaderMapper - Interface in org.springframework.pulsar.support

API for Pulsar message header mapper.

PulsarMessageListenerContainer - Interface in org.springframework.pulsar.listener

Internal abstraction used by the framework representing a message listener container.

PulsarMessageReceiverContext - Class in org.springframework.pulsar.observation

ReceiverContext for Pulsar messages.

PulsarMessageReceiverContext(Message<?>, String) - Constructor for class org.springframework.pulsar.observation.PulsarMessageReceiverContext

PulsarMessageRecoverer<T> - Interface in org.springframework.pulsar.listener

Allows recovering a failed Pulsar message.

PulsarMessageRecovererFactory<T> - Interface in org.springframework.pulsar.listener

Factory interface for PulsarMessageRecoverer.

PulsarMessageSenderContext - Class in org.springframework.pulsar.observation

SenderContext for Pulsar messages.

PulsarMessageSenderContext.MessageHolder - Class in org.springframework.pulsar.observation

Acts as a carrier for a Pulsar message and records the propagated properties for later access by the Pulsar message builder.

PulsarMessagingMessageConverter<V> - Class in org.springframework.pulsar.support.converter

A Messaging MessageConverter implementation for a message listener that receives individual messages.

PulsarMessagingMessageConverter(PulsarMessageHeaderMapper) - Constructor for class org.springframework.pulsar.support.converter.PulsarMessagingMessageConverter

PulsarMessagingMessageListenerAdapter<V> - Class in org.springframework.pulsar.listener.adapter

An abstract MessageListener adapter providing the necessary infrastructure to extract the payload from a Pulsar message.

PulsarMessagingMessageListenerAdapter(Object, Method) - Constructor for class org.springframework.pulsar.listener.adapter.PulsarMessagingMessageListenerAdapter

PulsarOperations<T> - Interface in org.springframework.pulsar.core

The basic Pulsar operations contract.

PulsarOperations.SendMessageBuilder<T> - Interface in org.springframework.pulsar.core

Builder that can be used to configure and send a message.

pulsarProducerCacheProvider() - Method in class org.springframework.pulsar.autoconfigure.PulsarReactiveAutoConfiguration

pulsarProducerFactory(PulsarClient) - Method in class org.springframework.pulsar.autoconfigure.PulsarAutoConfiguration

PulsarProducerFactory<T> - Interface in org.springframework.pulsar.core

The strategy to create a Producer instance(s).

PulsarProperties - Class in org.springframework.pulsar.autoconfigure

Configuration properties for Spring for Apache Pulsar.

PulsarProperties() - Constructor for class org.springframework.pulsar.autoconfigure.PulsarProperties

PulsarProperties.Admin - Class in org.springframework.pulsar.autoconfigure

PulsarProperties.Cache - Class in org.springframework.pulsar.autoconfigure

PulsarProperties.Client - Class in org.springframework.pulsar.autoconfigure

PulsarProperties.Consumer - Class in org.springframework.pulsar.autoconfigure

PulsarProperties.Listener - Class in org.springframework.pulsar.autoconfigure

PulsarProperties.Producer - Class in org.springframework.pulsar.autoconfigure

PulsarProperties.Template - Class in org.springframework.pulsar.autoconfigure

PulsarReactiveAnnotationDrivenConfiguration - Class in org.springframework.pulsar.autoconfigure

Configuration for Reactive Pulsar annotation-driven support.

PulsarReactiveAnnotationDrivenConfiguration(PulsarReactiveProperties) - Constructor for class org.springframework.pulsar.autoconfigure.PulsarReactiveAnnotationDrivenConfiguration

PulsarReactiveAutoConfiguration - Class in org.springframework.pulsar.autoconfigure

Auto-configuration for Apache Pulsar.

PulsarReactiveAutoConfiguration(PulsarReactiveProperties) - Constructor for class org.springframework.pulsar.autoconfigure.PulsarReactiveAutoConfiguration

pulsarReactiveMessageSenderCache(ObjectProvider<ProducerCacheProvider>) - Method in class org.springframework.pulsar.autoconfigure.PulsarReactiveAutoConfiguration

PulsarReactiveMessagingMessageListenerAdapter<V> - Class in org.springframework.pulsar.reactive.listener.adapter

An abstract base for MessageListener adapters.

PulsarReactiveMessagingMessageListenerAdapter(Object, Method) - Constructor for class org.springframework.pulsar.reactive.listener.adapter.PulsarReactiveMessagingMessageListenerAdapter

PulsarReactiveOneByOneMessagingMessageListenerAdapter<V> - Class in org.springframework.pulsar.reactive.listener.adapter

A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive individual messages.

PulsarReactiveOneByOneMessagingMessageListenerAdapter(Object, Method) - Constructor for class org.springframework.pulsar.reactive.listener.adapter.PulsarReactiveOneByOneMessagingMessageListenerAdapter

PulsarReactiveProperties - Class in org.springframework.pulsar.autoconfigure

Configuration properties for Spring for the Apache Pulsar reactive client.

PulsarReactiveProperties() - Constructor for class org.springframework.pulsar.autoconfigure.PulsarReactiveProperties

PulsarReactiveProperties.Cache - Class in org.springframework.pulsar.autoconfigure

PulsarReactiveProperties.Consumer - Class in org.springframework.pulsar.autoconfigure

PulsarReactiveProperties.Listener - Class in org.springframework.pulsar.autoconfigure

PulsarReactiveProperties.Reader - Class in org.springframework.pulsar.autoconfigure

PulsarReactiveProperties.SchedulerType - Enum Class in org.springframework.pulsar.autoconfigure

PulsarReactiveProperties.Sender - Class in org.springframework.pulsar.autoconfigure

pulsarReactivePulsarClient(PulsarClient) - Method in class org.springframework.pulsar.autoconfigure.PulsarReactiveAutoConfiguration

PulsarReactiveStreamingMessagingMessageListenerAdapter<V> - Class in org.springframework.pulsar.reactive.listener.adapter

A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive a flux of messages.

PulsarReactiveStreamingMessagingMessageListenerAdapter(Object, Method) - Constructor for class org.springframework.pulsar.reactive.listener.adapter.PulsarReactiveStreamingMessagingMessageListenerAdapter

pulsarReactiveTemplate(ReactivePulsarSenderFactory<?>) - Method in class org.springframework.pulsar.autoconfigure.PulsarReactiveAutoConfiguration

PulsarRecordMessageConverter<T> - Interface in org.springframework.pulsar.support.converter

Pulsar specific record converter strategy.

PulsarRecordMessageListener<T> - Interface in org.springframework.pulsar.listener

Base record MessageListener that simply extends from MessageListener.

PulsarRecordMessagingMessageListenerAdapter<V> - Class in org.springframework.pulsar.listener.adapter

A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive individual messages.

PulsarRecordMessagingMessageListenerAdapter<V> - Class in org.springframework.pulsar.reactive.listener.adapter

A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive individual messages.

PulsarRecordMessagingMessageListenerAdapter(Object, Method) - Constructor for class org.springframework.pulsar.listener.adapter.PulsarRecordMessagingMessageListenerAdapter

PulsarRecordMessagingMessageListenerAdapter(Object, Method) - Constructor for class org.springframework.pulsar.reactive.listener.adapter.PulsarRecordMessagingMessageListenerAdapter

PulsarRuntimeHints - Class in org.springframework.pulsar.aot

RuntimeHintsRegistrar for Spring for Apache Pulsar.

PulsarRuntimeHints() - Constructor for class org.springframework.pulsar.aot.PulsarRuntimeHints

pulsarTemplate(PulsarProducerFactory<?>, ObjectProvider<ProducerInterceptor>, ObjectProvider<ObservationRegistry>, ObjectProvider<PulsarTemplateObservationConvention>) - Method in class org.springframework.pulsar.autoconfigure.PulsarAutoConfiguration

PulsarTemplate<T> - Class in org.springframework.pulsar.core

A thread-safe template for executing high-level Pulsar operations.

PulsarTemplate(PulsarProducerFactory<T>) - Constructor for class org.springframework.pulsar.core.PulsarTemplate

Construct a template instance.

PulsarTemplate(PulsarProducerFactory<T>, List<ProducerInterceptor>) - Constructor for class org.springframework.pulsar.core.PulsarTemplate

Construct a template instance with optional interceptors.

PulsarTemplate(PulsarProducerFactory<T>, List<ProducerInterceptor>, ObservationRegistry, PulsarTemplateObservationConvention) - Constructor for class org.springframework.pulsar.core.PulsarTemplate

Construct a template instance with optional interceptors and observation configuration.

PulsarTemplate.SendMessageBuilderImpl<T> - Class in org.springframework.pulsar.core

PulsarTemplateObservation - Enum Class in org.springframework.pulsar.observation

An Observation for PulsarTemplate.

PulsarTemplateObservation.TemplateLowCardinalityTags - Enum Class in org.springframework.pulsar.observation

Low cardinality tags.

PulsarTemplateObservationConvention - Interface in org.springframework.pulsar.observation

ObservationConvention for Pulsar template key values.

PulsarTopic - Record Class in org.springframework.pulsar.core

Model class for a Pulsar topic.

PulsarTopic(String, int) - Constructor for record class org.springframework.pulsar.core.PulsarTopic

Creates an instance of a PulsarTopic record class.

PulsarTopicBuilder - Class in org.springframework.pulsar.core

Builder class to create PulsarTopic instances.

PulsarTopicBuilder(String) - Constructor for class org.springframework.pulsar.core.PulsarTopicBuilder

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