org.springframework.integration.kafka.dsl

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

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

Type Parameters:

K - the key type.

V - the outbound value type.

R - the reply value type.

S - the KafkaProducerMessageHandlerSpec extension type.

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, DisposableBean, FactoryBean<KafkaProducerMessageHandler<K,V>>, InitializingBean, Lifecycle, Phased, SmartLifecycle

Direct Known Subclasses:

KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec

public class KafkaOutboundGatewaySpec<K,V,R,S extends KafkaOutboundGatewaySpec<K,V,R,S>>
extends KafkaProducerMessageHandlerSpec<K,V,S>

A MessageHandlerSpec implementation for the KafkaProducerMessageHandler as a gateway.

Since:

5.4

Author:

Gary Russell

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R> A KafkaTemplate-based KafkaProducerMessageHandlerSpec extension.
static class	KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K,V,R> An IntegrationComponentSpec implementation for the KafkaTemplate.

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.context.SmartLifecycle

DEFAULT_PHASE

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

OBJECT_TYPE_ATTRIBUTE

Method Summary

Modifier and Type	Method and Description
S	replyMessageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter) Set a message converter for replies (when a gateway).

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

flush, flushExpression, flushExpression, futuresChannel, futuresChannel, headerMapper, messageKey, messageKey, messageKeyExpression, messageKeyExpression, partitionId, partitionId, partitionIdExpression, partitionIdExpression, sendFailureChannel, sendFailureChannel, sendSuccessChannel, sendSuccessChannel, sendTimeout, sync, timestamp, timestampExpression, timestampExpression, topic, topic, topicExpression, topicExpression

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

Methods inherited from class java.lang.Object

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

Method Detail

replyMessageConverter

public S replyMessageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)

Set a message converter for replies (when a gateway).

Parameters:

messageConverter - the converter.

Returns:

the spec.