Class KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R>
java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,H>
org.springframework.integration.dsl.MessageHandlerSpec<S,KafkaProducerMessageHandler<K,V>>
org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec<K,V,S>
org.springframework.integration.kafka.dsl.KafkaOutboundGatewaySpec<K,V,R,KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R>>
org.springframework.integration.kafka.dsl.KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R>
- Type Parameters:
K
- the key type.V
- the outbound value type.R
- the reply value type.
- All Implemented Interfaces:
Aware
,BeanClassLoaderAware
,BeanFactoryAware
,DisposableBean
,FactoryBean<KafkaProducerMessageHandler<K,
,V>> InitializingBean
,Lifecycle
,Phased
,SmartLifecycle
,ComponentsRegistration
- Enclosing class:
- KafkaOutboundGatewaySpec<K,
V, R, S extends KafkaOutboundGatewaySpec<K, V, R, S>>
public static class KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R>
extends KafkaOutboundGatewaySpec<K,V,R,KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R>>
implements ComponentsRegistration
A
KafkaTemplate
-based KafkaProducerMessageHandlerSpec
extension.-
Nested Class Summary
Nested classes/interfaces inherited from class org.springframework.integration.kafka.dsl.KafkaOutboundGatewaySpec
KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,
V, R>, KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K, V, R> Nested classes/interfaces inherited from class org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec
KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,
V> -
Field Summary
Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
PARSER, target
Fields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
logger
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 TypeMethodDescriptionconfigureKafkaTemplate
(Consumer<KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K, V, R>> configurer) Configure a Kafka Template by invoking theConsumer
callback, with aKafkaTemplateSpec
argument.Methods inherited from class org.springframework.integration.kafka.dsl.KafkaOutboundGatewaySpec
assigmentDuration, replyMessageConverter
Methods inherited from class org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec
flush, flushExpression, flushExpression, futuresChannel, futuresChannel, headerMapper, messageKey, messageKey, messageKeyExpression, messageKeyExpression, partitionId, partitionId, partitionIdExpression, partitionIdExpression, producerRecordCreator, sendFailureChannel, sendFailureChannel, sendSuccessChannel, sendSuccessChannel, sendTimeout, sync, timestamp, timestampExpression, timestampExpression, topic, topic, topicExpression, topicExpression, useTemplateConverter
Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop
Methods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
-
Method Details
-
configureKafkaTemplate
public KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V, configureKafkaTemplateR> (Consumer<KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K, V, R>> configurer) Configure a Kafka Template by invoking theConsumer
callback, with aKafkaTemplateSpec
argument.- Parameters:
configurer
- the configurer Java 8 Lambda.- Returns:
- the spec.
-
getComponentsToRegister
- Specified by:
getComponentsToRegister
in interfaceComponentsRegistration
-