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, setMethod
afterPropertiesSet, getAutoStartup, getBeanExpressionContext, getBeanFactory, getBeanResolver, getClientIdPrefix, getConcurrency, getConsumerProperties, getGroup, getGroupId, getId, getRecordFilterStrategy, getRecoveryCallback, getReplyTemplate, getResolver, getRetryTemplate, getTopicPartitionsToAssign, getTopicPattern, getTopics, isAckDiscarded, isBatchListener, isSplitIterables, isStatefulRetry, setAckDiscarded, setAutoStartup, setBatchListener, setBeanFactory, setClientIdPrefix, setConcurrency, setConsumerProperties, setGroup, setGroupId, setId, setRecordFilterStrategy, setRecoveryCallback, setReplyHeadersConfigurer, setReplyTemplate, setRetryTemplate, setSplitIterables, setStatefulRetry, setTopicPartitions, setTopicPartitions, setTopicPattern, setTopics, setupListenerContainer, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getTopicPartitions
public 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)
MethodKafkaListenerEndpoint
HandlerAdapter
for this listener adapter.configureListenerAdapter
in class MethodKafkaListenerEndpoint<K,V>
messageListener
- the listener adapter.