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, 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 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)
AbstractKafkaListenerEndpoint
MessageListener
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()
AbstractKafkaListenerEndpoint
getEndpointDescription
in class AbstractKafkaListenerEndpoint<K,V>
Available to subclasses, for inclusion in their toString()
result.