Package org.springframework.pulsar.listener.adapter

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:

• Serialized Form

Field Summary

Fields inherited from class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

logger

Constructor Summary

Constructors

Constructor	Description
PulsarRecordMessageToSpringMessageReaderAdapter(Object bean, Method method)

Method Summary

Modifier and Type	Method	Description
void	received(org.apache.pulsar.client.api.Reader<V> reader, org.apache.pulsar.client.api.Message<V> record)

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.ReaderListener

reachedEndOfTopic

Constructor Details

PulsarRecordMessageToSpringMessageReaderAdapter

public PulsarRecordMessageToSpringMessageReaderAdapter(Object bean,
 Method method)

Method Details

received

public void received(org.apache.pulsar.client.api.Reader<V> reader,
 org.apache.pulsar.client.api.Message<V> record)

Specified by:

received in interface org.apache.pulsar.client.api.ReaderListener<V>