Package org.springframework.kafka.listener.adapter

Class KafkaMessageHandlerMethodFactory

java.lang.Object

org.springframework.messaging.handler.annotation.support.DefaultMessageHandlerMethodFactory

org.springframework.kafka.listener.adapter.KafkaMessageHandlerMethodFactory

All Implemented Interfaces:

Aware, BeanFactoryAware, InitializingBean, MessageHandlerMethodFactory

public class KafkaMessageHandlerMethodFactory
extends DefaultMessageHandlerMethodFactory

Extension of the DefaultMessageHandlerMethodFactory for Spring Kafka requirements.

Since:

3.2

Author:

Wang Zhiyang

Constructor Summary

Constructors

Constructor	Description
KafkaMessageHandlerMethodFactory()

Method Summary

Modifier and Type	Method	Description
InvocableHandlerMethod	createInvocableHandlerMethod(Object bean, Method method)
protected List<HandlerMethodArgumentResolver>	initArgumentResolvers()
void	setMessageConverter(MessageConverter messageConverter)
void	setValidator(Validator validator)

Methods inherited from class org.springframework.messaging.handler.annotation.support.DefaultMessageHandlerMethodFactory

afterPropertiesSet, setArgumentResolvers, setBeanFactory, setConversionService, setCustomArgumentResolvers

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaMessageHandlerMethodFactory

public KafkaMessageHandlerMethodFactory()

Method Details

setMessageConverter

public void setMessageConverter(MessageConverter messageConverter)

Overrides:

setMessageConverter in class DefaultMessageHandlerMethodFactory

setValidator

public void setValidator(Validator validator)

Overrides:

setValidator in class DefaultMessageHandlerMethodFactory

initArgumentResolvers

protected List<HandlerMethodArgumentResolver> initArgumentResolvers()

Overrides:

initArgumentResolvers in class DefaultMessageHandlerMethodFactory

createInvocableHandlerMethod

public InvocableHandlerMethod createInvocableHandlerMethod(Object bean,
 Method method)

Specified by:

createInvocableHandlerMethod in interface MessageHandlerMethodFactory

Overrides:

createInvocableHandlerMethod in class DefaultMessageHandlerMethodFactory