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

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.

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

The bean name of the default PulsarListenerContainerFactory.

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

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

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

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

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

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

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

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

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

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

doCreateProducer(String, Schema<T>, MessageRouter, List<ProducerInterceptor>, 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

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