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:
-
Field Summary
Fields inherited from class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter
logger -
Constructor Summary
ConstructorsConstructorDescriptionPulsarBatchMessagesToSpringMessageListenerAdapter(Object bean, Method method) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidinvoke(Object records, org.apache.pulsar.client.api.Consumer<V> consumer, Message<?> message, Acknowledgement acknowledgement) voidreceived(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, toMessagingMessageFromReaderMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.pulsar.client.api.MessageListener
reachedEndOfTopicMethods inherited from interface org.springframework.pulsar.listener.PulsarBatchAcknowledgingMessageListener
receivedMethods inherited from interface org.springframework.pulsar.listener.PulsarBatchMessageListener
receivedMethods inherited from interface org.springframework.pulsar.listener.PulsarRecordMessageListener
received
-
Constructor Details
-
PulsarBatchMessagesToSpringMessageListenerAdapter
-
-
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:
receivedin interfacePulsarBatchAcknowledgingMessageListener<V>- Specified by:
receivedin interfacePulsarBatchMessageListener<V>
-
invoke
protected void invoke(Object records, org.apache.pulsar.client.api.Consumer<V> consumer, Message<?> message, Acknowledgement acknowledgement)
-