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

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

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

DefaultPulsarListenerObservationConvention - Class in org.springframework.pulsar.observation

Default PulsarListenerObservationConvention for Pulsar listener key values.

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

DefaultPulsarMessageHeaderMapper - Class in org.springframework.pulsar.support

Implementation of PulsarMessageHeaderMapper.

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

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

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

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

Default implementation of PulsarProducerFactory.

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

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, ReactiveMessageConsumerSpec) - Constructor for class org.springframework.pulsar.reactive.core.DefaultReactivePulsarConsumerFactory

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, ReactiveMessageReaderSpec) - Constructor for class org.springframework.pulsar.reactive.core.DefaultReactivePulsarReaderFactory

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

Default implementation of ReactivePulsarSenderFactory.

DefaultReactivePulsarSenderFactory(PulsarClient, ReactiveMessageSenderSpec, ReactiveMessageSenderCache) - Constructor for class org.springframework.pulsar.reactive.core.DefaultReactivePulsarSenderFactory

DefaultReactivePulsarSenderFactory(ReactivePulsarClient, ReactiveMessageSenderSpec, ReactiveMessageSenderCache) - Constructor for class org.springframework.pulsar.reactive.core.DefaultReactivePulsarSenderFactory

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

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

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

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

destroyInstance(PulsarClient) - Method in class org.springframework.pulsar.config.PulsarClientFactoryBean

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

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.

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

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

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

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

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.listener.DefaultReactivePulsarMessageListenerContainer

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