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

main(String[]) - Static method in class app1.SpringPulsarBootApp

main(String[]) - Static method in class app2.FailoverConsumerApp

main(String[]) - Static method in class org.springframework.pulsar.example.ReactiveSpringPulsarBootApp

main(String[]) - Static method in class org.springframework.pulsar.sample.binder.SpringPulsarBinderSampleApp

main(String[]) - Static method in class org.springframework.pulsar.sample.signup.SignupApplication

main(String[]) - Static method in class reader.app.SpringPulsarReaderBootApp

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

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() - Method in record class org.springframework.pulsar.autoconfigure.PulsarProperties.SchemaInfo

Returns the value of the messageKeyType record component.

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.

messageType() - Method in record class org.springframework.pulsar.autoconfigure.PulsarProperties.TypeMapping

Returns the value of the messageType record component.

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