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

M

MANUAL - Enum constant in enum class org.springframework.pulsar.listener.AckMode

Manual ack mode.

matchesForInbound(String) - Method in class org.springframework.pulsar.support.header.AbstractPulsarHeaderMapper

Determine if a header name matches any of the currently configured list of inbound matchers.

matchesForInbound(String) - Method in class org.springframework.pulsar.support.header.JsonPulsarHeaderMapper

matchesForOutbound(String) - Method in class org.springframework.pulsar.support.header.AbstractPulsarHeaderMapper

Determine if a header name matches any of the currently configured list of outbound matchers.

matchHandlerMethod(Class<? extends Object>, InvocableHandlerMethod) - Method in class org.springframework.pulsar.listener.adapter.DelegatingInvocableHandler

matchHeader(String) - Method in interface org.springframework.pulsar.support.header.PulsarHeaderMatcher

Determine if the header matches.

matchHeader(String) - Method in class org.springframework.pulsar.support.header.PulsarHeaderMatcher.NeverMatch

matchHeader(String) - Method in class org.springframework.pulsar.support.header.PulsarHeaderMatcher.PatternMatch

maybeLog(ProducerBuilderCustomizer<?>) - Method in class org.springframework.pulsar.support.internal.logging.LambdaCustomizerWarnLogger

Log a warning if the given customizer is implemented as a Lambda.

MESSAGE_ID - Static variable in class org.springframework.pulsar.support.PulsarHeaders

Unique message id.

MESSAGE_SIZE - Static variable in class org.springframework.pulsar.support.PulsarHeaders

Message size in bytes.

MessageConverter - Interface in org.springframework.pulsar.support

Pulsar specific message converter.

messageHandlerMethodFactory - Variable in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor

messageKeyType() - Element in annotation interface org.springframework.pulsar.annotation.PulsarMessage

The message key type when schema type is set to KEY_VALUE.

MessageListenerContainer - Interface in org.springframework.pulsar.listener

Internal abstraction used by the framework representing a message listener container.

MessageSpecBuilderCustomizer<T> - Interface in org.springframework.pulsar.reactive.core

The interface to customize a MessageSpecBuilder.

MessageUtils - Class in org.springframework.pulsar.reactive.support

Convenience functions related to Spring messages.

messageValueSchemaType() - Element in annotation interface org.springframework.pulsar.annotation.PulsarMessage

The default schema type to use for the value schema when PulsarMessage.schemaType() is set to KEY_VALUE.

MethodPulsarListenerEndpoint<V> - Class in org.springframework.pulsar.config

A PulsarListenerEndpoint providing the method to invoke to process an incoming message for this endpoint.

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

MethodPulsarReaderEndpoint<V> - Class in org.springframework.pulsar.config

A PulsarReaderEndpoint providing the method to invoke to process an incoming message for this endpoint.

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

MethodReactivePulsarListenerEndpoint<V> - Class in org.springframework.pulsar.reactive.config

A ReactivePulsarListenerEndpoint providing the method to invoke to process an incoming message for this endpoint.

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

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