Package org.springframework.pulsar.listener.adapter

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:

• Serialized Form

Field Summary

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

logger

Constructor Summary

Constructors

Constructor	Description
PulsarRecordMessageToSpringMessageListenerAdapter(Object bean, Method method)

Method Summary

Modifier and Type	Method	Description
void	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

public PulsarRecordMessageToSpringMessageListenerAdapter(Object bean,
 Method method)

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 interface PulsarAcknowledgingMessageListener<V>

Specified by:

received in interface PulsarRecordMessageListener<V>