K
- the key type.V
- the value type.public class MultiMethodKafkaListenerEndpoint<K,V> extends MethodKafkaListenerEndpoint<K,V>
MethodKafkaListenerEndpoint
extension for several POJO methods
based on the KafkaHandler
.KafkaHandler
,
DelegatingInvocableHandler
Constructor and Description |
---|
MultiMethodKafkaListenerEndpoint(java.util.List<java.lang.reflect.Method> methods,
java.lang.Object bean) |
Modifier and Type | Method and Description |
---|---|
protected HandlerAdapter |
configureListenerAdapter(MessagingMessageListenerAdapter<K,V> messageListener)
Create a
HandlerAdapter for this listener adapter. |
createMessageListener, createMessageListenerInstance, getBean, getEndpointDescription, getMessageHandlerMethodFactory, getMethod, setBean, setMessageHandlerMethodFactory, setMethod
afterPropertiesSet, getBeanExpressionContext, getBeanFactory, getGroup, getId, getRecordFilterStrategy, getRecoveryCallback, getResolver, getRetryTemplate, getTopicPartitions, getTopicPattern, getTopics, isAckDiscarded, isBatchListener, setAckDiscarded, setBatchListener, setBeanFactory, setGroup, setId, setRecordFilterStrategy, setRecoveryCallback, setRetryTemplate, setTopicPartitions, setTopicPattern, setTopics, setupListenerContainer, toString
public MultiMethodKafkaListenerEndpoint(java.util.List<java.lang.reflect.Method> methods, java.lang.Object bean)
protected HandlerAdapter configureListenerAdapter(MessagingMessageListenerAdapter<K,V> messageListener)
MethodKafkaListenerEndpoint
HandlerAdapter
for this listener adapter.configureListenerAdapter
in class MethodKafkaListenerEndpoint<K,V>
messageListener
- the listener adapter.