Index
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
- 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
- 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
- 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
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form