Package org.springframework.pulsar.listener.adapter

Class PulsarBatchMessagingMessageListenerAdapter<V>

java.lang.Object

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

org.springframework.pulsar.listener.adapter.PulsarBatchMessagingMessageListenerAdapter<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 PulsarBatchMessagingMessageListenerAdapter<V>
extends PulsarMessagingMessageListenerAdapter<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.PulsarMessagingMessageListenerAdapter

logger

Constructor Summary

Constructors

Constructor	Description
PulsarBatchMessagingMessageListenerAdapter(Object bean, Method method)

Method Summary

Modifier and Type	Method	Description
protected final PulsarBatchMessageConverter<V>	getBatchMessageConverter()
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)
void	setBatchMessageConverter(PulsarBatchMessageConverter<V> messageConverter)

Methods inherited from class org.springframework.pulsar.listener.adapter.PulsarMessagingMessageListenerAdapter

determineInferredType, getMessageConverter, getType, invokeHandler, isConsumerRecords, isFlux, isHeaderFound, isMessageList, isMultipleMessageType, isPulsarMessageList, isSimpleExtraction, isSpringMessage, isSpringMessageFlux, parameterIsType, setBeanResolver, setFallbackType, setHandlerMethod, setMessageConverter, setMessagingConverter, toMessagingMessage

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

PulsarBatchMessagingMessageListenerAdapter

public PulsarBatchMessagingMessageListenerAdapter(Object bean,
 Method method)

Method Details

setBatchMessageConverter

public void setBatchMessageConverter(PulsarBatchMessageConverter<V> messageConverter)

getBatchMessageConverter

protected final PulsarBatchMessageConverter<V> getBatchMessageConverter()

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)