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

D

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

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

The bean name or a SpEL expression that resolves to a DeadLetterPolicy to use on the consumer to configure a dead letter policy for message redelivery.

deadLetterPolicy() - Element in annotation interface org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListener

The bean name or a SpEL expression that resolves to a DeadLetterPolicy to use on the consumer to configure a dead letter policy for message redelivery.

DEFAULT_PULSAR_LISTENER_CONTAINER_FACTORY_BEAN_NAME - Static variable in class org.springframework.pulsar.annotation.PulsarListenerAnnotationBeanPostProcessor

The bean name of the default PulsarListenerContainerFactory.

DEFAULT_PULSAR_READER_CONTAINER_FACTORY_BEAN_NAME - Static variable in class org.springframework.pulsar.annotation.PulsarReaderAnnotationBeanPostProcessor

The bean name of the default PulsarReaderContainerFactory.

DEFAULT_REACTIVE_PULSAR_LISTENER_CONTAINER_FACTORY_BEAN_NAME - Static variable in class org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListenerAnnotationBeanPostProcessor

The bean name of the default ReactivePulsarListenerContainerFactory.

defaultFormattingConversionService - Variable in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor.PulsarHandlerMethodFactoryAdapter

DefaultPulsarClientFactory - Class in org.springframework.pulsar.core

Default implementation for PulsarClientFactory.

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

Construct a factory that creates clients using a default Pulsar client builder with no modifications other than the specified service url.

DefaultPulsarClientFactory(PulsarClientBuilderCustomizer) - Constructor for class org.springframework.pulsar.core.DefaultPulsarClientFactory

Construct a factory that creates clients using a customized Pulsar client builder.

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

Default implementation for PulsarConsumerErrorHandler.

DefaultPulsarConsumerErrorHandler(PulsarMessageRecovererFactory<T>, BackOff) - Constructor for class org.springframework.pulsar.listener.DefaultPulsarConsumerErrorHandler

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

Default implementation for PulsarConsumerFactory.

DefaultPulsarConsumerFactory(PulsarClient, List<ConsumerBuilderCustomizer<T>>) - Constructor for class org.springframework.pulsar.core.DefaultPulsarConsumerFactory

Construct a consumer factory instance.

DefaultPulsarListenerObservationConvention - Class in org.springframework.pulsar.observation

Default PulsarListenerObservationConvention for Pulsar listener key values.

DefaultPulsarListenerObservationConvention() - Constructor for class org.springframework.pulsar.observation.DefaultPulsarListenerObservationConvention

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

Default implementation for PulsarMessageListenerContainer.

DefaultPulsarMessageListenerContainer(PulsarConsumerFactory<? super T>, PulsarContainerProperties) - Constructor for class org.springframework.pulsar.listener.DefaultPulsarMessageListenerContainer

DefaultPulsarMessageReaderContainer<T> - Class in org.springframework.pulsar.reader

Default implementation for the Pulsar reader container.

DefaultPulsarMessageReaderContainer(PulsarReaderFactory<? super T>, PulsarReaderContainerProperties) - Constructor for class org.springframework.pulsar.reader.DefaultPulsarMessageReaderContainer

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

Default implementation of PulsarProducerFactory.

DefaultPulsarProducerFactory(PulsarClient) - Constructor for class org.springframework.pulsar.core.DefaultPulsarProducerFactory

Construct a producer factory that uses a default topic resolver.

DefaultPulsarProducerFactory(PulsarClient, String) - Constructor for class org.springframework.pulsar.core.DefaultPulsarProducerFactory

Construct a producer factory that uses a default topic resolver.

DefaultPulsarProducerFactory(PulsarClient, String, List<ProducerBuilderCustomizer<T>>) - Constructor for class org.springframework.pulsar.core.DefaultPulsarProducerFactory

Construct a producer factory that uses a default topic resolver.

DefaultPulsarProducerFactory(PulsarClient, String, List<ProducerBuilderCustomizer<T>>, TopicResolver) - Constructor for class org.springframework.pulsar.core.DefaultPulsarProducerFactory

Construct a producer factory that uses the specified parameters.

DefaultPulsarReaderContainerFactory<T> - Class in org.springframework.pulsar.config

Concrete implementation for PulsarReaderContainerFactory.

DefaultPulsarReaderContainerFactory(PulsarReaderFactory<? super T>, PulsarReaderContainerProperties) - Constructor for class org.springframework.pulsar.config.DefaultPulsarReaderContainerFactory

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

Default implementation of PulsarReaderFactory.

DefaultPulsarReaderFactory(PulsarClient) - Constructor for class org.springframework.pulsar.core.DefaultPulsarReaderFactory

Construct a reader factory instance with no default configuration.

DefaultPulsarReaderFactory(PulsarClient, List<ReaderBuilderCustomizer<T>>) - Constructor for class org.springframework.pulsar.core.DefaultPulsarReaderFactory

Construct a reader factory instance.

DefaultPulsarTemplateObservationConvention - Class in org.springframework.pulsar.observation

Default PulsarTemplateObservationConvention for Pulsar template key values.

DefaultPulsarTemplateObservationConvention() - Constructor for class org.springframework.pulsar.observation.DefaultPulsarTemplateObservationConvention

DefaultReactivePulsarConsumerFactory<T> - Class in org.springframework.pulsar.reactive.core

Default implementation for ReactivePulsarConsumerFactory.

DefaultReactivePulsarConsumerFactory(ReactivePulsarClient, List<ReactiveMessageConsumerBuilderCustomizer<T>>) - Constructor for class org.springframework.pulsar.reactive.core.DefaultReactivePulsarConsumerFactory

Construct an instance.

DefaultReactivePulsarListenerContainerFactory<T> - Class in org.springframework.pulsar.reactive.config

Concrete implementation for ReactivePulsarListenerContainerFactory.

DefaultReactivePulsarListenerContainerFactory(ReactivePulsarConsumerFactory<T>, ReactivePulsarContainerProperties<T>) - Constructor for class org.springframework.pulsar.reactive.config.DefaultReactivePulsarListenerContainerFactory

DefaultReactivePulsarMessageListenerContainer<T> - Class in org.springframework.pulsar.reactive.listener

Default implementation for ReactivePulsarMessageListenerContainer.

DefaultReactivePulsarMessageListenerContainer(ReactivePulsarConsumerFactory<T>, ReactivePulsarContainerProperties<T>) - Constructor for class org.springframework.pulsar.reactive.listener.DefaultReactivePulsarMessageListenerContainer

DefaultReactivePulsarReaderFactory<T> - Class in org.springframework.pulsar.reactive.core

Default implementation for ReactivePulsarReaderFactory.

DefaultReactivePulsarReaderFactory(ReactivePulsarClient, List<ReactiveMessageReaderBuilderCustomizer<T>>) - Constructor for class org.springframework.pulsar.reactive.core.DefaultReactivePulsarReaderFactory

Construct an instance.

DefaultReactivePulsarSenderFactory<T> - Class in org.springframework.pulsar.reactive.core

Default implementation of ReactivePulsarSenderFactory.

DefaultReactivePulsarSenderFactory.Builder<T> - Class in org.springframework.pulsar.reactive.core

Builder for DefaultReactivePulsarSenderFactory.

DefaultSchemaResolver - Class in org.springframework.pulsar.core

Default schema resolver capable of handling basic message types.

DefaultSchemaResolver() - Constructor for class org.springframework.pulsar.core.DefaultSchemaResolver

DefaultTopicResolver - Class in org.springframework.pulsar.core

Topic resolver that accepts custom type to topic mappings and uses the mappings during topic resolution.

DefaultTopicResolver() - Constructor for class org.springframework.pulsar.core.DefaultTopicResolver

DelegatingInvocableHandler - Class in org.springframework.pulsar.listener.adapter

Delegates to an InvocableHandlerMethod based on the message payload type.

DelegatingInvocableHandler(List<InvocableHandlerMethod>, InvocableHandlerMethod, Object, BeanExpressionResolver, BeanExpressionContext, BeanFactory, Validator) - Constructor for class org.springframework.pulsar.listener.adapter.DelegatingInvocableHandler

delete(PulsarAdmin) - Method in record class org.springframework.pulsar.function.PulsarFunction

delete(PulsarAdmin) - Method in interface org.springframework.pulsar.function.PulsarFunctionOperations

Deletes the function.

delete(PulsarAdmin) - Method in record class org.springframework.pulsar.function.PulsarSink

delete(PulsarAdmin) - Method in record class org.springframework.pulsar.function.PulsarSource

DELETE - Enum constant in enum class org.springframework.pulsar.function.PulsarFunctionOperations.FunctionStopPolicy

Delete the function.

destroy() - Method in class org.springframework.pulsar.config.GenericListenerEndpointRegistry

destroy() - Method in class org.springframework.pulsar.config.GenericReaderEndpointRegistry

destroy() - Method in class org.springframework.pulsar.core.CachingPulsarProducerFactory

destroy() - Method in interface org.springframework.pulsar.listener.MessageListenerContainer

destroy() - Method in class org.springframework.pulsar.reactive.core.DefaultReactivePulsarSenderFactory

destroy() - Method in interface org.springframework.pulsar.reader.PulsarMessageReaderContainer

determineInferredType(Method) - Method in class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

doCreateProducer(Schema<T>, String, Collection<String>, List<ProducerBuilderCustomizer<T>>) - Method in class org.springframework.pulsar.core.CachingPulsarProducerFactory

doCreateProducer(Schema<T>, String, Collection<String>, List<ProducerBuilderCustomizer<T>>) - Method in class org.springframework.pulsar.core.DefaultPulsarProducerFactory

Create the actual producer.

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

doPause() - Method in class org.springframework.pulsar.listener.ConcurrentPulsarMessageListenerContainer

doPause() - Method in class org.springframework.pulsar.listener.DefaultPulsarMessageListenerContainer

doResolveTopic(String, Class<?>, Supplier<String>) - Method in class org.springframework.pulsar.core.DefaultTopicResolver

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

doResume() - Method in class org.springframework.pulsar.listener.ConcurrentPulsarMessageListenerContainer

doResume() - Method in class org.springframework.pulsar.listener.DefaultPulsarMessageListenerContainer

doStart() - Method in class org.springframework.pulsar.core.AbstractPulsarMessageContainer

doStart() - Method in class org.springframework.pulsar.core.CachingPulsarProducerFactory

Callback invoked during startup - default implementation does nothing.

doStart() - Method in class org.springframework.pulsar.listener.ConcurrentPulsarMessageListenerContainer

doStart() - Method in class org.springframework.pulsar.listener.DefaultPulsarMessageListenerContainer

doStart() - Method in class org.springframework.pulsar.reactive.core.DefaultReactivePulsarSenderFactory

Callback invoked during startup - default implementation does nothing.

doStart() - Method in class org.springframework.pulsar.reader.DefaultPulsarMessageReaderContainer

doStop() - Method in class org.springframework.pulsar.core.AbstractPulsarMessageContainer

doStop() - Method in class org.springframework.pulsar.core.CachingPulsarProducerFactory

doStop() - Method in class org.springframework.pulsar.listener.ConcurrentPulsarMessageListenerContainer

doStop() - Method in class org.springframework.pulsar.listener.DefaultPulsarMessageListenerContainer

doStop() - Method in class org.springframework.pulsar.reactive.core.DefaultReactivePulsarSenderFactory

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

doStop() - Method in class org.springframework.pulsar.reader.DefaultPulsarMessageReaderContainer

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