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:
-
Field Summary
Fields inherited from class org.springframework.pulsar.listener.adapter.PulsarMessagingMessageListenerAdapter
logger
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected final PulsarBatchMessageConverter<V>
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
-
-
Method Details
-
setBatchMessageConverter
-
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 interfacePulsarBatchAcknowledgingMessageListener<V>
- Specified by:
received
in interfacePulsarBatchMessageListener<V>
-
invoke
protected void invoke(Object records, org.apache.pulsar.client.api.Consumer<V> consumer, Message<?> message, Acknowledgement acknowledgement)
-