Package org.springframework.kafka.config

Class MultiMethodKafkaListenerEndpoint<K,V>

java.lang.Object

org.springframework.kafka.config.AbstractKafkaListenerEndpoint<K,V>

org.springframework.kafka.config.MethodKafkaListenerEndpoint<K,V>

org.springframework.kafka.config.MultiMethodKafkaListenerEndpoint<K,V>

Type Parameters:

K - the key type.

V - the value type.

All Implemented Interfaces:

Aware, BeanFactoryAware, InitializingBean, KafkaListenerEndpoint

public class MultiMethodKafkaListenerEndpoint<K,V>
extends MethodKafkaListenerEndpoint<K,V>

The MethodKafkaListenerEndpoint extension for several POJO methods based on the KafkaHandler.

Author:

Gary Russell, Wang Zhiyang

See Also:

• KafkaHandler
• DelegatingInvocableHandler

Constructor Summary

Constructors

Constructor	Description
MultiMethodKafkaListenerEndpoint(List<Method> methods, Method defaultMethod, Object bean)	Construct an instance for the provided methods, default method and bean.

Method Summary

Modifier and Type	Method	Description
protected HandlerAdapter	configureListenerAdapter(MessagingMessageListenerAdapter<K,V> messageListener)	Create a HandlerAdapter for this listener adapter.
Method	getDefaultMethod()	Get a default method.
List<Method>	getMethods()	Get a method list.
void	setDefaultMethod(Method defaultMethod)	Set a default method.
void	setMethods(List<Method> methods)	Set a method list.
void	setValidator(Validator validator)	Set a payload validator.

Methods inherited from class org.springframework.kafka.config.MethodKafkaListenerEndpoint

createMessageListener, createMessageListenerInstance, getBean, getEndpointDescription, getMessageHandlerMethodFactory, getMethod, setBean, setErrorHandler, setMessageHandlerMethodFactory, setMessagingConverter, setMethod

Methods inherited from class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

afterPropertiesSet, getAutoStartup, getBatchListener, getBatchToRecordAdapter, getBeanExpressionContext, getBeanFactory, getBeanResolver, getClientIdPrefix, getConcurrency, getConsumerProperties, getContainerPostProcessor, getGroup, getGroupId, getId, getListenerInfo, getMainListenerId, getRecordFilterStrategy, getReplyTemplate, getResolver, getTopicPartitionsToAssign, getTopicPattern, getTopics, isAckDiscarded, isBatchListener, isSplitIterables, setAckDiscarded, setAutoStartup, setBatchListener, setBatchToRecordAdapter, setBeanFactory, setClientIdPrefix, setConcurrency, setConsumerProperties, setContainerPostProcessor, setCorrelationHeaderName, setGroup, setGroupId, setId, setListenerInfo, setMainListenerId, setRecordFilterStrategy, setReplyHeadersConfigurer, setReplyTemplate, setSplitIterables, setTopicPartitions, setTopicPattern, setTopics, setupListenerContainer, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

MultiMethodKafkaListenerEndpoint

public MultiMethodKafkaListenerEndpoint(List<Method> methods,
 @Nullable
 Method defaultMethod,
 Object bean)

Construct an instance for the provided methods, default method and bean.

Parameters:

methods - the methods.

defaultMethod - the default method.

bean - the bean.

Since:

2.1.3

Method Details

getMethods

public List<Method> getMethods()

Get a method list.

Returns:

the method list.

Since:

3.2

setMethods

public void setMethods(List<Method> methods)

Set a method list.

Parameters:

methods - the methods.

Since:

3.2

getDefaultMethod

public Method getDefaultMethod()

Get a default method.

Returns:

the default method.

Since:

3.2

setDefaultMethod

public void setDefaultMethod(Method defaultMethod)

Set a default method.

Parameters:

defaultMethod - the default method.

Since:

3.2

setValidator

public void setValidator(Validator validator)

Set a payload validator.

Parameters:

validator - the validator.

Since:

2.5.11

configureListenerAdapter

protected HandlerAdapter configureListenerAdapter(MessagingMessageListenerAdapter<K,V> messageListener)

Description copied from class: MethodKafkaListenerEndpoint

Create a HandlerAdapter for this listener adapter.

Overrides:

configureListenerAdapter in class MethodKafkaListenerEndpoint<K,V>

Parameters:

messageListener - the listener adapter.

Returns:

the handler adapter.