P-Index (Spring Pulsar 0.2.0 API)

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.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.
ProducerConfigProperties - Class in org.springframework.pulsar.autoconfigure: Configuration properties used to specify Pulsar producers.
ProducerConfigProperties() - Constructor for class org.springframework.pulsar.autoconfigure.ProducerConfigProperties
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
provisionConsumerDestination(String, String, ExtendedConsumerProperties<PulsarConsumerProperties>) - Method in class org.springframework.pulsar.spring.cloud.stream.binder.provisioning.PulsarTopicProvisioner
provisionProducerDestination(String, ExtendedProducerProperties<PulsarProducerProperties>) - Method in class org.springframework.pulsar.spring.cloud.stream.binder.provisioning.PulsarTopicProvisioner
PUBLISH_TIME - Static variable in class org.springframework.pulsar.support.PulsarHeaders: Message publish time (long).
PULSAR_CONTAINER - Static variable in interface org.springframework.pulsar.test.support.PulsarTestContainerSupport
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.
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
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
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
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
PulsarBinderConfiguration - Class in org.springframework.pulsar.spring.cloud.stream.binder.config: Pulsar binder Configuration.
PulsarBinderConfiguration() - Constructor for class org.springframework.pulsar.spring.cloud.stream.binder.config.PulsarBinderConfiguration
PulsarBinderConfigurationProperties - Class in org.springframework.pulsar.spring.cloud.stream.binder.properties: @ConfigurationProperties for the Pulsar binder.
PulsarBinderConfigurationProperties() - Constructor for class org.springframework.pulsar.spring.cloud.stream.binder.properties.PulsarBinderConfigurationProperties
PulsarBindingProperties - Class in org.springframework.pulsar.spring.cloud.stream.binder.properties: Container for Pulsar specific extended producer and consumer binding properties.
PulsarBindingProperties() - Constructor for class org.springframework.pulsar.spring.cloud.stream.binder.properties.PulsarBindingProperties
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
pulsarClientFactoryBean() - Method in class org.springframework.pulsar.autoconfigure.PulsarAutoConfiguration
PulsarClientFactoryBean - Class in org.springframework.pulsar.config: FactoryBean implementation for the PulsarClient.
PulsarClientFactoryBean(Map<String, Object>) - 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.
PulsarConsumerProperties - Class in org.springframework.pulsar.spring.cloud.stream.binder.properties: Pulsar consumer properties used by the binder.
PulsarConsumerProperties() - Constructor for class org.springframework.pulsar.spring.cloud.stream.binder.properties.PulsarConsumerProperties
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
PulsarExtendedBindingProperties - Class in org.springframework.pulsar.spring.cloud.stream.binder.properties: @ConfigurationProperties for Pulsar binder specific extensions to the common binding properties.
PulsarExtendedBindingProperties() - Constructor for class org.springframework.pulsar.spring.cloud.stream.binder.properties.PulsarExtendedBindingProperties
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(PulsarAdministration, ObjectProvider<PulsarFunction>, ObjectProvider<PulsarSink>, ObjectProvider<PulsarSource>) - Method in class org.springframework.pulsar.autoconfigure.PulsarAutoConfiguration
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() - Method in class org.springframework.pulsar.spring.cloud.stream.binder.config.PulsarBinderConfiguration
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.
pulsarMessageChannelBinder(PulsarTopicProvisioner, PulsarTemplate<Object>, PulsarConsumerFactory<byte[]>, PulsarBinderConfigurationProperties, PulsarExtendedBindingProperties, SchemaResolver, PulsarHeaderMapper) - Method in class org.springframework.pulsar.spring.cloud.stream.binder.config.PulsarBinderConfiguration
PulsarMessageChannelBinder - Class in org.springframework.pulsar.spring.cloud.stream.binder: Binder implementation for Apache Pulsar.
PulsarMessageChannelBinder(PulsarTopicProvisioner, PulsarTemplate<Object>, PulsarConsumerFactory<?>, PulsarBinderConfigurationProperties, SchemaResolver, PulsarHeaderMapper) - Constructor for class org.springframework.pulsar.spring.cloud.stream.binder.PulsarMessageChannelBinder
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.
pulsarProducerCacheProvider() - Method in class org.springframework.pulsar.autoconfigure.PulsarReactiveAutoConfiguration
pulsarProducerFactory(PulsarClient, TopicResolver) - Method in class org.springframework.pulsar.autoconfigure.PulsarAutoConfiguration
PulsarProducerFactory<T> - Interface in org.springframework.pulsar.core: The strategy to create a Producer instance(s).
PulsarProducerProperties - Class in org.springframework.pulsar.spring.cloud.stream.binder.properties: Pulsar producer properties used by the binder.
PulsarProducerProperties() - Constructor for class org.springframework.pulsar.spring.cloud.stream.binder.properties.PulsarProducerProperties
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.Defaults - Class in org.springframework.pulsar.autoconfigure
PulsarProperties.Function - Class in org.springframework.pulsar.autoconfigure
PulsarProperties.Listener - Class in org.springframework.pulsar.autoconfigure
PulsarProperties.Reader - Class in org.springframework.pulsar.autoconfigure
PulsarProperties.SchemaInfo - Record Class in org.springframework.pulsar.autoconfigure: Represents a schema - holds enough information to construct an actual schema instance.
PulsarProperties.Template - Class in org.springframework.pulsar.autoconfigure
PulsarProperties.TypeMapping - Record Class in org.springframework.pulsar.autoconfigure: A mapping from message type to topic and/or schema info to use (at least one of topicName or schemaInfo must be specified.
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<?>, SchemaResolver, TopicResolver) - Method in class org.springframework.pulsar.autoconfigure.PulsarReactiveAutoConfiguration
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(PulsarClient) - Method in class org.springframework.pulsar.autoconfigure.PulsarAutoConfiguration
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(PulsarProducerFactory<?>, ObjectProvider<ProducerInterceptor>, SchemaResolver, TopicResolver, ObjectProvider<ObservationRegistry>, ObjectProvider<PulsarTemplateObservationConvention>) - Method in class org.springframework.pulsar.autoconfigure.PulsarAutoConfiguration
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.
PulsarTemplate(PulsarProducerFactory<T>, List<ProducerInterceptor>, SchemaResolver, TopicResolver, ObservationRegistry, PulsarTemplateObservationConvention) - 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.
PulsarTestContainerSupport - Interface in org.springframework.pulsar.test.support: Provides a static PulsarContainer that can be shared across test classes.
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
pulsarTopicProvisioner(PulsarAdministration, PulsarBinderConfigurationProperties) - Method in class org.springframework.pulsar.spring.cloud.stream.binder.config.PulsarBinderConfiguration
PulsarTopicProvisioner - Class in org.springframework.pulsar.spring.cloud.stream.binder.provisioning: Pulsar topic provisioner.
PulsarTopicProvisioner(PulsarAdministration, PulsarBinderConfigurationProperties) - Constructor for class org.springframework.pulsar.spring.cloud.stream.binder.provisioning.PulsarTopicProvisioner

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