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

N

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

Negatively acknowledges the current message manually.

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

Negative acknowledges the current message based on the message id.

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

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

Gets the name of the function.

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

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

negativeAcknowledge(Message<T>) - Static method in class org.springframework.pulsar.reactive.support.MessageUtils

Convenience method that negatively acknowledges a Spring message by extracting its message id and passing it to MessageResult.negativeAcknowledge(MessageId).

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

negativeAckRedeliveryBackoff() - 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 a negative ack.

NeverMatch(String...) - Constructor for class org.springframework.pulsar.support.header.PulsarHeaderMatcher.NeverMatch

newContext(String, String) - Static method in class org.springframework.pulsar.observation.PulsarMessageSenderContext

newMessage(T) - Method in interface org.springframework.pulsar.core.PulsarOperations

Create a builder for configuring and sending a message.

newMessage(T) - Method in class org.springframework.pulsar.core.PulsarTemplate

newMessage(T) - Method in interface org.springframework.pulsar.reactive.core.ReactivePulsarOperations

Create a builder for configuring and sending a message reactively.

newMessage(T) - Method in class org.springframework.pulsar.reactive.core.ReactivePulsarTemplate

newMessages(Publisher<MessageSpec<T>>) - Method in interface org.springframework.pulsar.reactive.core.ReactivePulsarOperations

Create a builder for configuring and sending multiple messages reactively.

newMessages(Publisher<MessageSpec<T>>) - Method in class org.springframework.pulsar.reactive.core.ReactivePulsarTemplate

noBeanFoundMessage(Object, String, String, Class<?>) - Method in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor

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

Do nothing - leave the function alone.

NonTrustedHeaderType(String, String) - Constructor for record class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper.NonTrustedHeaderType

Creates an instance of a NonTrustedHeaderType record class.

numberOfPartitions() - Method in record class org.springframework.pulsar.core.PulsarTopic

Returns the value of the numberOfPartitions record component.

numberOfPartitions(int) - Method in class org.springframework.pulsar.core.PulsarTopicBuilder

Sets the number of topic partitions.

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