Class PulsarRecordMessageToSpringMessageReaderAdapter<V>
java.lang.Object
org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter<V>
org.springframework.pulsar.listener.adapter.PulsarRecordMessageToSpringMessageReaderAdapter<V>
- Type Parameters:
V- payload type.
- All Implemented Interfaces:
Serializable,org.apache.pulsar.client.api.ReaderListener<V>
public class PulsarRecordMessageToSpringMessageReaderAdapter<V>
extends AbstractPulsarMessageToSpringMessageAdapter<V>
implements org.apache.pulsar.client.api.ReaderListener<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
Constructors -
Method Summary
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, toMessagingMessageFromReaderMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.pulsar.client.api.ReaderListener
reachedEndOfTopic