Package 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	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.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Method Summary

Modifier and Type	Method	Description
S	assigmentDuration(Duration duration)	Set the time to wait for partition assignment, when used as a gateway, to determine the default reply-to topic/partition.
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, 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

Methods inherited from class java.lang.Object

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

Method Details

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.

assigmentDuration

public S assigmentDuration(Duration duration)

Set the time to wait for partition assignment, when used as a gateway, to determine the default reply-to topic/partition.

Parameters:

duration - the duration.

Returns:

the spec.

Since:

6.0