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

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

PatternMatch(String, boolean) - Constructor for class org.springframework.pulsar.support.header.PulsarHeaderMatcher.PatternMatch

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

pause() - Method in interface org.springframework.pulsar.listener.PulsarMessageListenerContainer

Pause this container before the next poll().

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

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

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

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

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

processPulsarReader(PulsarReader, Method, Object, String) - Method in class org.springframework.pulsar.annotation.PulsarReaderAnnotationBeanPostProcessor

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

processReader(MethodPulsarReaderEndpoint<?>, PulsarReader, Object, String, String[]) - Method in class org.springframework.pulsar.annotation.PulsarReaderAnnotationBeanPostProcessor

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

Producer name.

ProducerBuilderConfigurationUtil - Class in org.springframework.pulsar.core

Utility methods to help load configuration into a ProducerBuilder.

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

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

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.

PULSAR_READER_ANNOTATION_PROCESSOR_BEAN_NAME - Static variable in class org.springframework.pulsar.config.PulsarAnnotationSupportBeanNames

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

PULSAR_READER_ENDPOINT_REGISTRY_BEAN_NAME - Static variable in class org.springframework.pulsar.config.PulsarAnnotationSupportBeanNames

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.

PulsarAdminBuilderCustomizer - Interface in org.springframework.pulsar.core

The interface to customize a PulsarAdminBuilder.

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(String) - Constructor for class org.springframework.pulsar.core.PulsarAdministration

Construct a default instance using the specified service url.

PulsarAdministration(List<PulsarAdminBuilderCustomizer>) - Constructor for class org.springframework.pulsar.core.PulsarAdministration

Construct an instance with the specified customizations.

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

Construct an instance with the specified customizations.

PulsarAdministrationOperations - Interface in org.springframework.pulsar.core

The Pulsar administration contract.

PulsarAnnotationsConfigurationSelector - Class in org.springframework.pulsar.annotation

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

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

PulsarAnnotationSupportBeanNames - Class in org.springframework.pulsar.config

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

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

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

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

Batch message listener.

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

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

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

PulsarClientBuilderCustomizer - Interface in org.springframework.pulsar.core

The interface to customize a ClientBuilder.

PulsarClientFactory - Interface in org.springframework.pulsar.core

Pulsar client factory interface.

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

PulsarFunction - Record Class in org.springframework.pulsar.function

Represents a user-defined Pulsar Function backed by a FunctionConfig.

PulsarFunction(FunctionConfig, UpdateOptions) - Constructor for record class org.springframework.pulsar.function.PulsarFunction

PulsarFunction(FunctionConfig, PulsarFunctionOperations.FunctionStopPolicy, UpdateOptions) - Constructor for record class org.springframework.pulsar.function.PulsarFunction

Creates an instance of a PulsarFunction record class.

PulsarFunctionAdministration - Class in org.springframework.pulsar.function

Responsible for creating and updating any user-defined Pulsar functions, sinks, or sources.

PulsarFunctionAdministration(PulsarAdministration, ObjectProvider<PulsarFunction>, ObjectProvider<PulsarSink>, ObjectProvider<PulsarSource>, boolean, boolean, boolean) - Constructor for class org.springframework.pulsar.function.PulsarFunctionAdministration

Construct a PulsarFunctionAdministration instance.

PulsarFunctionAdministration.PulsarFunctionException - Exception in org.springframework.pulsar.function

Indicates a failure of one or more function operations.

PulsarFunctionException(String, Map<PulsarFunctionOperations<?>, Exception>) - Constructor for exception org.springframework.pulsar.function.PulsarFunctionAdministration.PulsarFunctionException

PulsarFunctionOperations<T> - Interface in org.springframework.pulsar.function

Provides operations for a particular function type.

PulsarFunctionOperations.FunctionStopPolicy - Enum Class in org.springframework.pulsar.function

The action to take on the function when the server stops.

PulsarFunctionOperations.FunctionType - Enum Class in org.springframework.pulsar.function

The type of function the operations handle.

PulsarHandlerMethodFactoryAdapter() - Constructor for class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor.PulsarHandlerMethodFactoryAdapter

PulsarHeaderMapper - Interface in org.springframework.pulsar.support.header

Defines the contract for mapping Spring Messaging MessageHeaders to and from Pulsar message headers.

PulsarHeaderMatcher - Interface in org.springframework.pulsar.support.header

Defines the contract for matching message headers.

PulsarHeaderMatcher.NeverMatch - Class in org.springframework.pulsar.support.header

A matcher that never matches a set of headers.

PulsarHeaderMatcher.PatternMatch - Class in org.springframework.pulsar.support.header

A pattern-based header matcher that matches if the specified header matches the specified simple pattern.

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

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

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.

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

Pulsar specific record converter strategy.

PulsarMessageListenerContainer - Interface in org.springframework.pulsar.listener

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

PulsarMessageReaderContainer - Interface in org.springframework.pulsar.reader

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.

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<T> - Interface in org.springframework.pulsar.core

The strategy to create a Producer instance(s).

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

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

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

PulsarReaderAnnotationBeanPostProcessor<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 PulsarReaderContainerFactory according to the parameters of the annotation.

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

PulsarReaderConfigurer - Interface in org.springframework.pulsar.annotation

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

PulsarReaderContainerFactory - Interface in org.springframework.pulsar.config

Container factory for PulsarMessageReaderContainer.

PulsarReaderContainerProperties - Class in org.springframework.pulsar.reader

Container properties for Pulsar Reader.

PulsarReaderContainerProperties() - Constructor for class org.springframework.pulsar.reader.PulsarReaderContainerProperties

PulsarReaderContainerRegistry - Interface in org.springframework.pulsar.reader

Reader container registry.

PulsarReaderEndpoint<C extends PulsarMessageReaderContainer> - Interface in org.springframework.pulsar.config

Model for a Pulsar Reader endpoint.

PulsarReaderEndpointRegistrar - Class in org.springframework.pulsar.config

Helper bean for registering PulsarReaderEndpoint with a GenericReaderEndpointRegistry.

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

PulsarReaderEndpointRegistry - Class in org.springframework.pulsar.config

Creates the necessary PulsarMessageReaderContainer instances for the registered endpoints.

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

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

Pulsar Reader factory interface.

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

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

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

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

Base record MessageListener that simply extends from MessageListener.

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

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

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

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

PulsarRuntimeHints - Class in org.springframework.pulsar.aot

RuntimeHintsRegistrar for Spring for Apache Pulsar.

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

PulsarSink - Record Class in org.springframework.pulsar.function

Represents a Pulsar Sink backed by a SinkConfig.

PulsarSink(SinkConfig, UpdateOptions) - Constructor for record class org.springframework.pulsar.function.PulsarSink

PulsarSink(SinkConfig, PulsarFunctionOperations.FunctionStopPolicy, UpdateOptions) - Constructor for record class org.springframework.pulsar.function.PulsarSink

Creates an instance of a PulsarSink record class.

PulsarSource - Record Class in org.springframework.pulsar.function

Represents a Pulsar Source backed by a SourceConfig.

PulsarSource(SourceConfig, UpdateOptions) - Constructor for record class org.springframework.pulsar.function.PulsarSource

PulsarSource(SourceConfig, PulsarFunctionOperations.FunctionStopPolicy, UpdateOptions) - Constructor for record class org.springframework.pulsar.function.PulsarSource

Creates an instance of a PulsarSource record class.

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

A template for executing high-level Pulsar operations.

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

Construct a template instance without interceptors that uses the default schema resolver.

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

Construct a template instance with interceptors that uses the default schema resolver and default topic resolver and enables observation recording.

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

Construct a template instance with optional 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