K - the key type.V - the value type.public class MethodKafkaListenerEndpoint<K,V> extends AbstractKafkaListenerEndpoint<K,V>
KafkaListenerEndpoint providing the method to invoke to process
an incoming message for this endpoint.| Constructor and Description |
|---|
MethodKafkaListenerEndpoint() |
| Modifier and Type | Method and Description |
|---|---|
protected HandlerAdapter |
configureListenerAdapter(MessagingMessageListenerAdapter<K,V> messageListener)
Create a
HandlerAdapter for this listener adapter. |
protected MessagingMessageListenerAdapter<K,V> |
createMessageListener(MessageListenerContainer container,
MessageConverter messageConverter)
Create a
MessageListener that is able to serve this endpoint for the
specified container. |
protected MessagingMessageListenerAdapter<K,V> |
createMessageListenerInstance(MessageConverter messageConverter)
Create an empty
MessagingMessageListenerAdapter instance. |
java.lang.Object |
getBean() |
protected java.lang.StringBuilder |
getEndpointDescription()
Return a description for this endpoint.
|
protected org.springframework.messaging.handler.annotation.support.MessageHandlerMethodFactory |
getMessageHandlerMethodFactory()
Return the
MessageHandlerMethodFactory. |
java.lang.reflect.Method |
getMethod() |
void |
setBean(java.lang.Object bean)
Set the object instance that should manage this endpoint.
|
void |
setErrorHandler(KafkaListenerErrorHandler errorHandler)
Set the
KafkaListenerErrorHandler to invoke if the listener method
throws an exception. |
void |
setMessageHandlerMethodFactory(org.springframework.messaging.handler.annotation.support.MessageHandlerMethodFactory messageHandlerMethodFactory)
Set the
MessageHandlerMethodFactory to use to build the
InvocableHandlerMethod responsible to manage the invocation
of this endpoint. |
void |
setMethod(java.lang.reflect.Method method)
Set the method to invoke to process a message managed by this endpoint.
|
afterPropertiesSet, getBeanExpressionContext, getBeanFactory, getBeanResolver, getGroup, getGroupId, getId, getRecordFilterStrategy, getRecoveryCallback, getReplyTemplate, getResolver, getRetryTemplate, getTopicPartitions, getTopicPattern, getTopics, isAckDiscarded, isBatchListener, setAckDiscarded, setBatchListener, setBeanFactory, setGroup, setGroupId, setId, setRecordFilterStrategy, setRecoveryCallback, setReplyTemplate, setRetryTemplate, setTopicPartitions, setTopicPattern, setTopics, setupListenerContainer, toStringpublic void setBean(java.lang.Object bean)
bean - the target bean instance.public java.lang.Object getBean()
public void setMethod(java.lang.reflect.Method method)
method - the target method for the bean.public java.lang.reflect.Method getMethod()
public void setMessageHandlerMethodFactory(org.springframework.messaging.handler.annotation.support.MessageHandlerMethodFactory messageHandlerMethodFactory)
MessageHandlerMethodFactory to use to build the
InvocableHandlerMethod responsible to manage the invocation
of this endpoint.messageHandlerMethodFactory - the MessageHandlerMethodFactory instance.public void setErrorHandler(KafkaListenerErrorHandler errorHandler)
KafkaListenerErrorHandler to invoke if the listener method
throws an exception.errorHandler - the error handler.protected org.springframework.messaging.handler.annotation.support.MessageHandlerMethodFactory getMessageHandlerMethodFactory()
MessageHandlerMethodFactory.protected MessagingMessageListenerAdapter<K,V> createMessageListener(MessageListenerContainer container, MessageConverter messageConverter)
AbstractKafkaListenerEndpointMessageListener that is able to serve this endpoint for the
specified container.createMessageListener in class AbstractKafkaListenerEndpoint<K,V>container - the MessageListenerContainer to create a MessageListener.messageConverter - the message converter - may be null.MessageListener instance.protected HandlerAdapter configureListenerAdapter(MessagingMessageListenerAdapter<K,V> messageListener)
HandlerAdapter for this listener adapter.messageListener - the listener adapter.protected MessagingMessageListenerAdapter<K,V> createMessageListenerInstance(MessageConverter messageConverter)
MessagingMessageListenerAdapter instance.messageConverter - the converter (may be null).MessagingMessageListenerAdapter instance.protected java.lang.StringBuilder getEndpointDescription()
AbstractKafkaListenerEndpointgetEndpointDescription in class AbstractKafkaListenerEndpoint<K,V>Available to subclasses, for inclusion in their toString() result.