Class MyListener
- java.lang.Object
-
- org.springframework.kafka.jdocs.dynamic.MyListener
-
- All Implemented Interfaces:
GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String,java.lang.String>>,MessageListener<java.lang.String,java.lang.String>
public class MyListener extends java.lang.Object implements MessageListener<java.lang.String,java.lang.String>
MessageListenerfor dynamic containers.- Since:
- 2.8.9
- Author:
- Gary Russell
-
-
Constructor Summary
Constructors Constructor Description MyListener()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidonMessage(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String,java.lang.String> data)Invoked with data from kafka.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.springframework.kafka.listener.GenericMessageListener
onMessage, onMessage, onMessage
-
-
-
-
Method Detail
-
onMessage
public void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String,java.lang.String> data)
Description copied from interface:GenericMessageListenerInvoked with data from kafka.- Specified by:
onMessagein interfaceGenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String,java.lang.String>>- Parameters:
data- the data to be processed.
-
-