Class PulsarRecordMessageToSpringMessageListenerAdapter<V>
java.lang.Object
org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter<V>
org.springframework.pulsar.listener.adapter.PulsarRecordMessageToSpringMessageListenerAdapter<V>
- Type Parameters:
V
- payload type.
- All Implemented Interfaces:
Serializable
,org.apache.pulsar.client.api.MessageListener<V>
,PulsarAcknowledgingMessageListener<V>
,PulsarRecordMessageListener<V>
public class PulsarRecordMessageToSpringMessageListenerAdapter<V>
extends AbstractPulsarMessageToSpringMessageAdapter<V>
implements PulsarAcknowledgingMessageListener<V>
A
MessageListener
adapter that invokes a configurable
HandlerAdapter
; used when the factory is configured for the listener to receive
individual messages.- Author:
- Soby Chacko
- See Also:
-
Field Summary
Fields inherited from class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter
logger
-
Constructor Summary
ConstructorsConstructorDescriptionPulsarRecordMessageToSpringMessageListenerAdapter
(Object bean, Method method) -
Method Summary
Modifier and TypeMethodDescriptionvoid
received
(org.apache.pulsar.client.api.Consumer<V> consumer, org.apache.pulsar.client.api.Message<V> record, Acknowledgement acknowledgement) Methods inherited from class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter
determineInferredType, getMessageConverter, getType, invokeHandler, isConsumerRecords, isFlux, isHeaderFound, isMessageList, isMultipleMessageType, isPulsarMessageList, isSimpleExtraction, isSpringMessage, isSpringMessageFlux, parameterIsType, setBeanResolver, setFallbackType, setHandlerMethod, setMessageConverter, setMessagingConverter, toMessagingMessage, toMessagingMessageFromReader
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.pulsar.client.api.MessageListener
reachedEndOfTopic
Methods inherited from interface org.springframework.pulsar.listener.PulsarAcknowledgingMessageListener
received
-
Constructor Details
-
PulsarRecordMessageToSpringMessageListenerAdapter
-
-
Method Details
-
received
public void received(org.apache.pulsar.client.api.Consumer<V> consumer, org.apache.pulsar.client.api.Message<V> record, @Nullable Acknowledgement acknowledgement) - Specified by:
received
in interfacePulsarAcknowledgingMessageListener<V>
- Specified by:
received
in interfacePulsarRecordMessageListener<V>
-