Interface GenericMessageListener<T>
-
- Type Parameters:
T- the type received by the listener.
- All Known Subinterfaces:
AcknowledgingConsumerAwareMessageListener<K,V>,AcknowledgingMessageListener<K,V>,BatchAcknowledgingConsumerAwareMessageListener<K,V>,BatchAcknowledgingMessageListener<K,V>,BatchConsumerAwareMessageListener<K,V>,BatchMessageListener<K,V>,ConsumerAwareMessageListener<K,V>,MessageListener<K,V>
- All Known Implementing Classes:
AggregatingReplyingKafkaTemplate,BatchMessagingMessageListenerAdapter,FilteringBatchMessageListenerAdapter,FilteringMessageListenerAdapter,KafkaBackoffAwareMessageListenerAdapter,RecordMessagingMessageListenerAdapter,ReplyingKafkaTemplate,RetryingMessageListenerAdapter
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public interface GenericMessageListener<T>Top level interface for listeners.- Since:
- 1.1
- Author:
- Gary Russell
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description voidonMessage(T data)Invoked with data from kafka.default voidonMessage(T data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)Invoked with data from kafka and provides access to theConsumer.default voidonMessage(T data, Acknowledgment acknowledgment)Invoked with data from kafka.default voidonMessage(T data, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)Invoked with data from kafka and provides access to theConsumer.
-
-
-
Method Detail
-
onMessage
void onMessage(T data)
Invoked with data from kafka.- Parameters:
data- the data to be processed.
-
onMessage
default void onMessage(T data, @Nullable Acknowledgment acknowledgment)
Invoked with data from kafka. The default implementation throwsUnsupportedOperationException.- Parameters:
data- the data to be processed.acknowledgment- the acknowledgment.
-
onMessage
default void onMessage(T data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
Invoked with data from kafka and provides access to theConsumer. The default implementation throwsUnsupportedOperationException.- Parameters:
data- the data to be processed.consumer- the consumer.- Since:
- 2.0
-
onMessage
default void onMessage(T data, @Nullable Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
Invoked with data from kafka and provides access to theConsumer. The default implementation throwsUnsupportedOperationException.- Parameters:
data- the data to be processed.acknowledgment- the acknowledgment.consumer- the consumer.- Since:
- 2.0
-
-