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

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

Manual ack mode.

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

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.

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.

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

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