org.springframework.integration.kafka.inbound
Class KafkaMessageDrivenChannelAdapter

java.lang.Object
  extended by org.springframework.integration.context.IntegrationObjectSupport
      extended by org.springframework.integration.endpoint.AbstractEndpoint
          extended by org.springframework.integration.endpoint.MessageProducerSupport
              extended by org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, org.springframework.integration.context.OrderlyShutdownCapable, org.springframework.integration.core.MessageProducer, org.springframework.integration.history.TrackableComponent, org.springframework.integration.support.context.NamedComponent

public class KafkaMessageDrivenChannelAdapter
extends org.springframework.integration.endpoint.MessageProducerSupport
implements org.springframework.integration.context.OrderlyShutdownCapable


Field Summary
 
Fields inherited from class org.springframework.integration.endpoint.AbstractEndpoint
lifecycleCondition, lifecycleLock
 
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport
logger
 
Constructor Summary
KafkaMessageDrivenChannelAdapter(KafkaMessageListenerContainer messageListenerContainer)
           
 
Method Summary
 int afterShutdown()
           
 int beforeShutdown()
           
protected  void doStart()
           
protected  void doStop()
           
 java.lang.String getComponentType()
           
protected  void onInit()
           
 void setKeyDecoder(kafka.serializer.Decoder<?> keyDecoder)
           
 void setPayloadDecoder(kafka.serializer.Decoder<?> payloadDecoder)
           
 
Methods inherited from class org.springframework.integration.endpoint.MessageProducerSupport
sendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrack
 
Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint
getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop
 
Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.springframework.integration.support.context.NamedComponent
getComponentName
 

Constructor Detail

KafkaMessageDrivenChannelAdapter

public KafkaMessageDrivenChannelAdapter(KafkaMessageListenerContainer messageListenerContainer)
Method Detail

setKeyDecoder

public void setKeyDecoder(kafka.serializer.Decoder<?> keyDecoder)

setPayloadDecoder

public void setPayloadDecoder(kafka.serializer.Decoder<?> payloadDecoder)

onInit

protected void onInit()
Overrides:
onInit in class org.springframework.integration.endpoint.MessageProducerSupport

doStart

protected void doStart()
Overrides:
doStart in class org.springframework.integration.endpoint.MessageProducerSupport

doStop

protected void doStop()
Overrides:
doStop in class org.springframework.integration.endpoint.MessageProducerSupport

getComponentType

public java.lang.String getComponentType()
Specified by:
getComponentType in interface org.springframework.integration.support.context.NamedComponent
Overrides:
getComponentType in class org.springframework.integration.context.IntegrationObjectSupport

beforeShutdown

public int beforeShutdown()
Specified by:
beforeShutdown in interface org.springframework.integration.context.OrderlyShutdownCapable

afterShutdown

public int afterShutdown()
Specified by:
afterShutdown in interface org.springframework.integration.context.OrderlyShutdownCapable