public class KafkaProducerMessageHandler<K,V>
extends org.springframework.integration.handler.AbstractMessageHandler
| Constructor and Description |
|---|
KafkaProducerMessageHandler(KafkaProducerContext<K,V> kafkaProducerContext) |
| Modifier and Type | Method and Description |
|---|---|
KafkaProducerContext<K,V> |
getKafkaProducerContext() |
protected void |
handleMessageInternal(org.springframework.messaging.Message<?> message) |
getComponentType, getOrder, handleMessage, setOrder, setShouldTrackafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, onInit, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toStringpublic KafkaProducerMessageHandler(KafkaProducerContext<K,V> kafkaProducerContext)
public KafkaProducerContext<K,V> getKafkaProducerContext()
protected void handleMessageInternal(org.springframework.messaging.Message<?> message)
throws java.lang.Exception
handleMessageInternal in class org.springframework.integration.handler.AbstractMessageHandlerjava.lang.Exception