org.springframework.integration.dsl.kafka

Class KafkaMessageDrivenChannelAdapterSpec<K,V,S extends KafkaMessageDrivenChannelAdapterSpec<K,V,S>>

java.lang.Object

org.springframework.integration.dsl.core.IntegrationComponentSpec<S,P>

org.springframework.integration.dsl.core.MessageProducerSpec<S,org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter<K,V>>

org.springframework.integration.dsl.kafka.KafkaMessageDrivenChannelAdapterSpec<K,V,S>

Type Parameters:

K - the key type.

V - the value type.

S - the target KafkaMessageDrivenChannelAdapterSpec implementation type.

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter<K,V>>

Direct Known Subclasses:

KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec

public class KafkaMessageDrivenChannelAdapterSpec<K,V,S extends KafkaMessageDrivenChannelAdapterSpec<K,V,S>>
extends MessageProducerSpec<S,org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter<K,V>>

A MessageProducerSpec implementation for the KafkaMessageDrivenChannelAdapter.

Since:

1.2

Author:

Artem Bilan

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> A ConcurrentMessageListenerContainer configuration KafkaMessageDrivenChannelAdapterSpec extension.
static class	KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V> A helper class in the Builder pattern style to delegate options to the ConcurrentMessageListenerContainer.

Field Summary

Fields inherited from class org.springframework.integration.dsl.core.IntegrationComponentSpec

logger, PARSER, target

Method Summary

Modifier and Type	Method and Description
KafkaMessageDrivenChannelAdapterSpec<K,V,S>	batchMode(boolean batchMode)
protected org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter<K,V>	doGet()

Methods inherited from class org.springframework.integration.dsl.core.MessageProducerSpec

autoStartup, errorChannel, errorChannel, id, outputChannel, outputChannel, phase

Methods inherited from class org.springframework.integration.dsl.core.IntegrationComponentSpec

_this, get, getId, getObject, getObjectType, isSingleton

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

batchMode

public KafkaMessageDrivenChannelAdapterSpec<K,V,S> batchMode(boolean batchMode)

doGet

protected org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter<K,V> doGet()

Overrides:

doGet in class IntegrationComponentSpec<S extends KafkaMessageDrivenChannelAdapterSpec<K,V,S>,org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter<K,V>>