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, setErrorHandler, setMessageHandlerMethodFactory, setMethod
afterPropertiesSet, getBeanExpressionContext, getBeanFactory, getGroup, getGroupId, getId, getRecordFilterStrategy, getRecoveryCallback, getResolver, getRetryTemplate, getTopicPartitions, getTopicPattern, getTopics, isAckDiscarded, isBatchListener, setAckDiscarded, setBatchListener, setBeanFactory, setGroup, setGroupId, 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.