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

A

AbstractPulsarListenerContainerFactory<C extends AbstractPulsarMessageListenerContainer<T>,T> - Class in org.springframework.pulsar.config

Base PulsarListenerContainerFactory implementation.

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

AbstractPulsarListenerEndpoint<K> - Class in org.springframework.pulsar.config

Base implementation for PulsarListenerEndpoint.

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

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

Base implementation for the PulsarMessageListenerContainer.

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

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

Base implementation for ReactivePulsarListenerEndpoint.

AbstractReactivePulsarListenerEndpoint() - Constructor for class org.springframework.pulsar.reactive.config.AbstractReactivePulsarListenerEndpoint

acceptIfCondition(boolean, T1, T2, BiConsumer<T1, T2>) - Method in class org.springframework.pulsar.support.JavaUtils

Invoke BiConsumer.accept(Object, Object) with the arguments if the condition is true.

acceptIfCondition(boolean, T, Consumer<T>) - Method in class org.springframework.pulsar.support.JavaUtils

Invoke Consumer.accept(Object) with the value if the condition is true.

acceptIfHasText(String, Consumer<String>) - Method in class org.springframework.pulsar.support.JavaUtils

Invoke Consumer.accept(Object) with the value if it is not null or empty.

acceptIfHasText(T, String, BiConsumer<T, String>) - Method in class org.springframework.pulsar.support.JavaUtils

Invoke BiConsumer.accept(Object, Object) with the arguments if the value argument is not null or empty.

acceptIfInstanceOf(Class<T>, Object, Consumer<T>) - Method in class org.springframework.pulsar.support.JavaUtils

Invoke Consumer.accept(Object) with the cast value if the object is an instance of the provided class.

acceptIfNotEmpty(List<T>, Consumer<List<T>>) - Method in class org.springframework.pulsar.support.JavaUtils

Invoke Consumer.accept(Object) with the value if it is not null or empty.

acceptIfNotEmpty(T[], Consumer<T[]>) - Method in class org.springframework.pulsar.support.JavaUtils

Invoke Consumer.accept(Object) with the value if it is not null or empty.

acceptIfNotNull(T1, T2, BiConsumer<T1, T2>) - Method in class org.springframework.pulsar.support.JavaUtils

Invoke BiConsumer.accept(Object, Object) with the arguments if the t2 argument is not null.

acceptIfNotNull(T, Consumer<T>) - Method in class org.springframework.pulsar.support.JavaUtils

Invoke Consumer.accept(Object) with the value if it is not null.

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

Override the container default ack mode of BATCH.

AckMode - Enum Class in org.springframework.pulsar.listener

Enumeration for ack mode.

acknowledge() - Method in interface org.springframework.pulsar.listener.Acknowledgement

Manually acknowledges the current message that the listener is operating upon.

acknowledge(List<MessageId>) - Method in interface org.springframework.pulsar.listener.Acknowledgement

Manually acknowledges a list of messages based on their message id's.

acknowledge(MessageId) - Method in interface org.springframework.pulsar.listener.Acknowledgement

Manually acknowledges by the message id.

Acknowledgement - Interface in org.springframework.pulsar.listener

Contract for manual acknowledgment.

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

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

The bean name or a 'SpEL' expression that resolves to a RedeliveryBackoff to use on the consumer to control the redelivery backoff of messages after an acknowledgment timeout.

Admin() - Constructor for class org.springframework.pulsar.autoconfigure.PulsarProperties.Admin

afterPropertiesSet() - Method in class org.springframework.pulsar.annotation.PulsarListenerAnnotationBeanPostProcessor

afterPropertiesSet() - Method in class org.springframework.pulsar.config.AbstractPulsarListenerEndpoint

afterPropertiesSet() - Method in class org.springframework.pulsar.config.PulsarListenerEndpointRegistrar

afterPropertiesSet() - Method in class org.springframework.pulsar.reactive.config.AbstractReactivePulsarListenerEndpoint

afterPropertiesSet() - Method in class org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListenerAnnotationBeanPostProcessor

afterSingletonsInstantiated() - Method in class org.springframework.pulsar.annotation.PulsarListenerAnnotationBeanPostProcessor

afterSingletonsInstantiated() - Method in class org.springframework.pulsar.core.PulsarAdministration

afterSingletonsInstantiated() - Method in class org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListenerAnnotationBeanPostProcessor

app1 - package app1

Package containing sample app for the framework.

app2 - package app2

Package containing sample app for the framework.

assertBeanFactory() - Method in class org.springframework.pulsar.annotation.PulsarListenerAnnotationBeanPostProcessor

assertBeanFactory() - Method in class org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListenerAnnotationBeanPostProcessor

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

Set to true or false, to override the default setting in the container factory.

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

Set to true or false, to override the default setting in the container factory.

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