Package org.springframework.pulsar.listener.adapter

Class PulsarBatchMessagesToSpringMessageListenerAdapter<V>

java.lang.Object

org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter<V>

org.springframework.pulsar.listener.adapter.PulsarBatchMessagesToSpringMessageListenerAdapter<V>

Type Parameters:

V - payload type.

All Implemented Interfaces:

Serializable, org.apache.pulsar.client.api.MessageListener<V>, PulsarBatchAcknowledgingMessageListener<V>, PulsarBatchMessageListener<V>, PulsarRecordMessageListener<V>

public class PulsarBatchMessagesToSpringMessageListenerAdapter<V>
extends AbstractPulsarMessageToSpringMessageAdapter<V>
implements PulsarBatchAcknowledgingMessageListener<V>

A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive batches of 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
PulsarBatchMessagesToSpringMessageListenerAdapter(Object bean, Method method)

Method Summary

Modifier and Type	Method	Description
protected void	invoke(Object records, org.apache.pulsar.client.api.Consumer<V> consumer, Message<?> message, Acknowledgement acknowledgement)
void	received(org.apache.pulsar.client.api.Consumer<V> consumer, List<org.apache.pulsar.client.api.Message<V>> msg, 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.PulsarBatchAcknowledgingMessageListener

received

Methods inherited from interface org.springframework.pulsar.listener.PulsarBatchMessageListener

received

Methods inherited from interface org.springframework.pulsar.listener.PulsarRecordMessageListener

received

Constructor Details

PulsarBatchMessagesToSpringMessageListenerAdapter

public PulsarBatchMessagesToSpringMessageListenerAdapter(Object bean,
 Method method)

Method Details

received

public void received(org.apache.pulsar.client.api.Consumer<V> consumer,
 List<org.apache.pulsar.client.api.Message<V>> msg,
 @Nullable
 Acknowledgement acknowledgement)

Specified by:

received in interface PulsarBatchAcknowledgingMessageListener<V>

Specified by:

received in interface PulsarBatchMessageListener<V>

invoke

protected void invoke(Object records,
 org.apache.pulsar.client.api.Consumer<V> consumer,
 Message<?> message,
 Acknowledgement acknowledgement)