Package org.springframework.integration.kafka.dsl

Class KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K,V,R>

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<KafkaTemplateSpec<K,V>,org.springframework.kafka.core.KafkaTemplate<K,V>>

org.springframework.integration.kafka.dsl.KafkaTemplateSpec<K,V>

org.springframework.integration.kafka.dsl.KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K,V,R>

Type Parameters:

K - the key type.

V - the request value type.

R - the reply value type.

All Implemented Interfaces:

DisposableBean, FactoryBean<org.springframework.kafka.core.KafkaTemplate<K,V>>, InitializingBean, Lifecycle, Phased, SmartLifecycle

Enclosing class:

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

public static class KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K,V,R>
extends KafkaTemplateSpec<K,V>

An IntegrationComponentSpec implementation for the KafkaTemplate.

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
KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K,V,R>	defaultReplyTimeout(Duration replyTimeout)	Default reply timeout.
KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K,V,R>	taskScheduler(TaskScheduler scheduler)

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

defaultTopic, getTemplate, id, messageConverter, producerListener

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

taskScheduler

public KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K,V,R> taskScheduler(TaskScheduler scheduler)

defaultReplyTimeout

public KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K,V,R> defaultReplyTimeout(Duration replyTimeout)

Default reply timeout.

Parameters:

replyTimeout - the timeout.

Returns:

the spec.