Uses of Interface
org.springframework.pulsar.support.MessageConverter
Package
Description
Package containing Spring configuration classes for the framework.
Package containing Spring configuration classes for the framework.
Package containing message converters.
-
Uses of MessageConverter in org.springframework.pulsar.config
Modifier and TypeMethodDescriptionprotected abstract AbstractPulsarMessageToSpringMessageAdapter<K>
AbstractPulsarListenerEndpoint.createMessageListener
(PulsarMessageListenerContainer container, MessageConverter messageConverter) protected AbstractPulsarMessageToSpringMessageAdapter<V>
MethodPulsarListenerEndpoint.createMessageListener
(PulsarMessageListenerContainer container, MessageConverter messageConverter) protected AbstractPulsarMessageToSpringMessageAdapter<V>
MethodPulsarListenerEndpoint.createMessageListenerInstance
(MessageConverter messageConverter) protected AbstractPulsarMessageToSpringMessageAdapter<V>
MethodPulsarReaderEndpoint.createMessageListenerInstance
(MessageConverter messageConverter) protected abstract AbstractPulsarMessageToSpringMessageAdapter<K>
AbstractPulsarReaderEndpoint.createReaderListener
(PulsarMessageReaderContainer container, MessageConverter messageConverter) protected AbstractPulsarMessageToSpringMessageAdapter<V>
MethodPulsarReaderEndpoint.createReaderListener
(PulsarMessageReaderContainer container, MessageConverter messageConverter) void
AbstractPulsarListenerContainerFactory.setMessageConverter
(MessageConverter messageConverter) Set the message converter to use if dynamic argument type matching is needed.void
AbstractPulsarReaderContainerFactory.setMessageConverter
(MessageConverter messageConverter) Set the message converter to use if dynamic argument type matching is needed.void
AbstractPulsarListenerEndpoint.setupListenerContainer
(PulsarMessageListenerContainer listenerContainer, MessageConverter messageConverter) void
AbstractPulsarReaderEndpoint.setupListenerContainer
(PulsarMessageReaderContainer listenerContainer, MessageConverter messageConverter) default void
ListenerEndpoint.setupListenerContainer
(C listenerContainer, MessageConverter messageConverter) Setup the specified message listener container with the model defined by this endpoint.void
PulsarReaderEndpoint.setupListenerContainer
(C listenerContainer, MessageConverter messageConverter) Setup the specified message listener container with the model defined by this endpoint. -
Uses of MessageConverter in org.springframework.pulsar.reactive.config
Modifier and TypeMethodDescriptionprotected abstract AbstractPulsarMessageToSpringMessageAdapter<T>
AbstractReactivePulsarListenerEndpoint.createMessageHandler
(ReactivePulsarMessageListenerContainer<T> container, MessageConverter messageConverter) protected AbstractPulsarMessageToSpringMessageAdapter<V>
MethodReactivePulsarListenerEndpoint.createMessageHandler
(ReactivePulsarMessageListenerContainer<V> container, MessageConverter messageConverter) protected AbstractPulsarMessageToSpringMessageAdapter<V>
MethodReactivePulsarListenerEndpoint.createMessageListenerInstance
(MessageConverter messageConverter) void
DefaultReactivePulsarListenerContainerFactory.setMessageConverter
(MessageConverter messageConverter) Set the message converter to use if dynamic argument type matching is needed.void
AbstractReactivePulsarListenerEndpoint.setupListenerContainer
(ReactivePulsarMessageListenerContainer<T> listenerContainer, MessageConverter messageConverter) -
Uses of MessageConverter in org.springframework.pulsar.support.converter
Modifier and TypeInterfaceDescriptioninterface
Pulsar specific record converter strategy.Modifier and TypeClassDescriptionclass
A MessagingMessageConverter
implementation for a message listener that receives individual messages.