Uses of Class
org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter
Package
Description
Package containing Spring configuration classes for the framework.
Package containing components for adapting Pulsar messages to message listeners.
Package containing Spring configuration classes for the framework.
Package containing listener components for receiving Pulsar messages.
-
Uses of AbstractPulsarMessageToSpringMessageAdapter 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) Modifier and TypeMethodDescriptionprotected HandlerAdapter
MethodPulsarListenerEndpoint.configureListenerAdapter
(AbstractPulsarMessageToSpringMessageAdapter<V> messageListener) protected HandlerAdapter
MethodPulsarReaderEndpoint.configureListenerAdapter
(AbstractPulsarMessageToSpringMessageAdapter<V> messageListener) -
Uses of AbstractPulsarMessageToSpringMessageAdapter in org.springframework.pulsar.listener.adapter
Modifier and TypeClassDescriptionclass
AMessageListener
adapter that invokes a configurableHandlerAdapter
; used when the factory is configured for the listener to receive batches of messages.class
AMessageListener
adapter that invokes a configurableHandlerAdapter
; used when the factory is configured for the listener to receive individual messages.class
AMessageListener
adapter that invokes a configurableHandlerAdapter
; used when the factory is configured for the listener to receive individual messages. -
Uses of AbstractPulsarMessageToSpringMessageAdapter 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) Modifier and TypeMethodDescriptionprotected HandlerAdapter
MethodReactivePulsarListenerEndpoint.configureListenerAdapter
(AbstractPulsarMessageToSpringMessageAdapter<V> messageListener) -
Uses of AbstractPulsarMessageToSpringMessageAdapter in org.springframework.pulsar.reactive.listener.adapter
Modifier and TypeClassDescriptionclass
An abstract base forMessageListener
adapters.class
AMessageListener
adapter that invokes a configurableHandlerAdapter
; used when the factory is configured for the listener to receive individual messages.class
AMessageListener
adapter that invokes a configurableHandlerAdapter
; used when the factory is configured for the listener to receive a flux of messages.