Index

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

P

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

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

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

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

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

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

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.

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 - Variable in class org.springframework.pulsar.listener.AbstractPulsarMessageListenerContainer

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

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 a 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<C extends PulsarMessageListenerContainer> - 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 PulsarListenerEndpoint with a PulsarListenerEndpointRegistry.

PulsarListenerEndpointRegistrar() - 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

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

Container annotation that aggregates several PulsarListener annotations.

PulsarMessageListenerContainer - Interface in org.springframework.pulsar.listener

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

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.

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

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

PulsarMessagingMessageConverter() - 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.

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

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(Object, Method) - Constructor for class org.springframework.pulsar.listener.adapter.PulsarRecordMessagingMessageListenerAdapter

pulsarTemplate(PulsarProducerFactory<?>, ObjectProvider<ProducerInterceptor>) - 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.

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

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 L M N O P R S T V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form