org.springframework.integration.dsl.kafka

Class KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V>

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,KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V>>

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

Type Parameters:

K - the key type.

V - the value type.

All Implemented Interfaces:

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

Enclosing class:

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

public static class KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V>
extends KafkaMessageDrivenChannelAdapterSpec<K,V,KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V>>
implements ComponentsRegistration

A ConcurrentMessageListenerContainer configuration KafkaMessageDrivenChannelAdapterSpec extension.

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.integration.dsl.kafka.KafkaMessageDrivenChannelAdapterSpec

KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V>, KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V>

Field Summary

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

logger, PARSER, target

Method Summary

Modifier and Type	Method and Description
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V>	configureListenerContainer(Consumer<KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V>> configurer) Configure a listener container by invoking the Consumer callback, with a KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec argument.
java.util.Collection<java.lang.Object>	getComponentsToRegister()

Methods inherited from class org.springframework.integration.dsl.kafka.KafkaMessageDrivenChannelAdapterSpec

batchMode, 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

configureListenerContainer

public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> configureListenerContainer(Consumer<KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V>> configurer)

Configure a listener container by invoking the Consumer callback, with a KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec argument.

Parameters:

configurer - the configurer Java 8 Lambda.

Returns:

the spec.

getComponentsToRegister

public java.util.Collection<java.lang.Object> getComponentsToRegister()

Specified by:

getComponentsToRegister in interface ComponentsRegistration