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.reflect.Method defaultMethod,
java.lang.Object bean)
Construct an instance for the provided methods, default method and bean.
|
MultiMethodKafkaListenerEndpoint(java.util.List<java.lang.reflect.Method> methods,
java.lang.Object bean)
Construct an instance for the provided methods and bean with no default method.
|
| 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, setMethodafterPropertiesSet, getBeanExpressionContext, getBeanFactory, getBeanResolver, getClientIdPrefix, getGroup, getGroupId, getId, getRecordFilterStrategy, getRecoveryCallback, getReplyTemplate, getResolver, getRetryTemplate, getTopicPartitions, getTopicPattern, getTopics, isAckDiscarded, isBatchListener, isStatefulRetry, setAckDiscarded, setBatchListener, setBeanFactory, setClientIdPrefix, setGroup, setGroupId, setId, setRecordFilterStrategy, setRecoveryCallback, setReplyTemplate, setRetryTemplate, setStatefulRetry, setTopicPartitions, setTopicPattern, setTopics, setupListenerContainer, toStringpublic MultiMethodKafkaListenerEndpoint(java.util.List<java.lang.reflect.Method> methods,
java.lang.Object bean)
methods - the methods.bean - the bean.public MultiMethodKafkaListenerEndpoint(java.util.List<java.lang.reflect.Method> methods,
@Nullable
java.lang.reflect.Method defaultMethod,
java.lang.Object bean)
methods - the methods.defaultMethod - the default method.bean - the bean.protected HandlerAdapter configureListenerAdapter(MessagingMessageListenerAdapter<K,V> messageListener)
MethodKafkaListenerEndpointHandlerAdapter for this listener adapter.configureListenerAdapter in class MethodKafkaListenerEndpoint<K,V>messageListener - the listener adapter.