Package org.springframework.integration.kafka.dsl

Class KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R>

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<S,G>

org.springframework.integration.dsl.MessagingGatewaySpec<S,KafkaInboundGateway<K,V,R>>

org.springframework.integration.kafka.dsl.KafkaInboundGatewaySpec<K,V,R,KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R>>

org.springframework.integration.kafka.dsl.KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R>

Type Parameters:

K - the key type.

V - the request value type.

R - the reply value type.

All Implemented Interfaces:

DisposableBean, FactoryBean<KafkaInboundGateway<K,V,R>>, InitializingBean, Lifecycle, Phased, SmartLifecycle, ComponentsRegistration

Enclosing class:

KafkaInboundGatewaySpec<K,V,R,S extends KafkaInboundGatewaySpec<K,V,R,S>>

public static class KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R>
extends KafkaInboundGatewaySpec<K,V,R,KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R>>

A ConcurrentMessageListenerContainer configuration KafkaInboundGatewaySpec extension.

Nested Class Summary

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

KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R>

Field Summary

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

logger, PARSER, target

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Method Summary

Modifier and Type	Method	Description
KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R>	configureListenerContainer(Consumer<KafkaMessageListenerContainerSpec<K,V>> configurer)	Configure a listener container by invoking the Consumer callback, with a KafkaMessageListenerContainerSpec argument.
KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R>	configureTemplate(Consumer<KafkaTemplateSpec<K,R>> configurer)	Configure a template by invoking the Consumer callback, with a KafkaTemplateSpec argument.
Map<Object,String>	getComponentsToRegister()

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

messageConverter, onPartitionsAssignedSeekCallback, recoveryCallback, retryTemplate

Methods inherited from class org.springframework.integration.dsl.MessagingGatewaySpec

autoStartup, errorChannel, errorChannel, errorOnTimeout, id, observationConvention, phase, replyChannel, replyChannel, replyMapper, replyTimeout, requestChannel, requestChannel, requestMapper, requestTimeout, shouldTrack

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

_this, afterPropertiesSet, destroy, doGet, getId, getObject, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.beans.factory.FactoryBean

isSingleton

Method Details

configureListenerContainer

public KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R> configureListenerContainer(Consumer<KafkaMessageListenerContainerSpec<K,V>> configurer)

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

Parameters:

configurer - the configurer Java 8 Lambda.

Returns:

the spec.

configureTemplate

public KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R> configureTemplate(Consumer<KafkaTemplateSpec<K,R>> configurer)

Configure a template by invoking the Consumer callback, with a KafkaTemplateSpec argument.

Parameters:

configurer - the configurer Java 8 Lambda.

Returns:

the spec.

getComponentsToRegister

public Map<Object,String> getComponentsToRegister()

Specified by:

getComponentsToRegister in interface ComponentsRegistration

Overrides:

getComponentsToRegister in class KafkaInboundGatewaySpec<K,V,R,KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R>>