K - the key type.V - the value type.public class SimpleKafkaListenerEndpoint<K,V> extends AbstractKafkaListenerEndpoint<K,V>
KafkaListenerEndpoint simply providing the MessageListener to
invoke to process an incoming message for this endpoint.| Constructor and Description |
|---|
SimpleKafkaListenerEndpoint() |
| Modifier and Type | Method and Description |
|---|---|
protected MessageListener<K,V> |
createMessageListener(MessageListenerContainer container,
MessageConverter messageConverter)
Create a
MessageListener that is able to serve this endpoint for the
specified container. |
protected java.lang.StringBuilder |
getEndpointDescription()
Return a description for this endpoint.
|
MessageListener<K,V> |
getMessageListener()
Return the
MessageListener to invoke when a message matching
the endpoint is received. |
void |
setMessageListener(MessageListener<K,V> messageListener)
Set the
MessageListener to invoke when a message matching
the endpoint is received. |
afterPropertiesSet, getBeanExpressionContext, getBeanFactory, getGroup, getId, getRecordFilterStrategy, getRecoveryCallback, getResolver, getRetryTemplate, getTopicPartitions, getTopicPattern, getTopics, isAckDiscarded, setAckDiscarded, setBeanFactory, setGroup, setId, setRecordFilterStrategy, setRecoveryCallback, setRetryTemplate, setTopicPartitions, setTopicPattern, setTopics, setupListenerContainer, toStringpublic void setMessageListener(MessageListener<K,V> messageListener)
MessageListener to invoke when a message matching
the endpoint is received.messageListener - the MessageListener instance.public MessageListener<K,V> getMessageListener()
MessageListener to invoke when a message matching
the endpoint is received.MessageListener to invoke when a message matching
the endpoint is received.protected MessageListener<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 java.lang.StringBuilder getEndpointDescription()
AbstractKafkaListenerEndpointgetEndpointDescription in class AbstractKafkaListenerEndpoint<K,V>Available to subclasses, for inclusion in their toString() result.