Class PulsarRecordMessagingMessageListenerAdapter<V>
java.lang.Object
org.springframework.pulsar.listener.adapter.PulsarMessagingMessageListenerAdapter<V>
org.springframework.pulsar.reactive.listener.adapter.PulsarRecordMessagingMessageListenerAdapter<V>
- Type Parameters:
V- payload type.
- All Implemented Interfaces:
Serializable,org.apache.pulsar.client.api.MessageListener<V>,PulsarAcknowledgingMessageListener<V>,PulsarRecordMessageListener<V>
public class PulsarRecordMessagingMessageListenerAdapter<V>
extends PulsarMessagingMessageListenerAdapter<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:
-
Field Summary
Fields inherited from class org.springframework.pulsar.listener.adapter.PulsarMessagingMessageListenerAdapter
logger -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidreceived(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.PulsarMessagingMessageListenerAdapter
determineInferredType, getMessageConverter, getType, invokeHandler, isConsumerRecords, isFlux, isHeaderFound, isMessageList, isMultipleMessageType, isPulsarMessageList, isSimpleExtraction, isSpringMessage, isSpringMessageFlux, parameterIsType, setBeanResolver, setFallbackType, setHandlerMethod, setMessageConverter, setMessagingConverter, toMessagingMessageMethods 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.PulsarAcknowledgingMessageListener
received
-
Constructor Details
-
PulsarRecordMessagingMessageListenerAdapter
-
-
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:
receivedin interfacePulsarAcknowledgingMessageListener<V>- Specified by:
receivedin interfacePulsarRecordMessageListener<V>
-